Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6ed8f159e7 | ||
|
|
c9133edfd9 | ||
|
|
fed21bfb86 | ||
|
|
981e1e0cf0 | ||
|
|
7db81a88e4 |
70
apapter/atomic.go
Normal file
70
apapter/atomic.go
Normal file
@ -0,0 +1,70 @@
|
|||||||
|
package apapter
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"errors"
|
||||||
|
"sync/atomic"
|
||||||
|
|
||||||
|
"github.com/gogf/gf/v2/container/gvar"
|
||||||
|
"github.com/gogf/gf/v2/encoding/gbase64"
|
||||||
|
"github.com/gogf/gf/v2/encoding/gjson"
|
||||||
|
"github.com/gogf/gf/v2/frame/g"
|
||||||
|
"google.golang.org/grpc/metadata"
|
||||||
|
)
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 原子钟接口配置
|
||||||
|
* @author dc.To
|
||||||
|
* @version 20250807
|
||||||
|
*/
|
||||||
|
type AtomicAdapter struct {
|
||||||
|
store atomic.Value
|
||||||
|
adapter string
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewAtomicAdapter(ctx context.Context, adapter string) *AtomicAdapter {
|
||||||
|
a := &AtomicAdapter{adapter: adapter}
|
||||||
|
md, ok := metadata.FromIncomingContext(ctx)
|
||||||
|
if ok {
|
||||||
|
if c := md.Get(a.adapter); len(c) > 0 {
|
||||||
|
a.SetContent(gjson.New(gbase64.MustDecodeToString(c[0])).Map())
|
||||||
|
} else {
|
||||||
|
g.Log("cfg").Error(ctx, "No Metadata from incoming cfg context")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return a
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AtomicAdapter) SetContent(content map[string]interface{}) error {
|
||||||
|
a.store.Store(content)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AtomicAdapter) Available(ctx context.Context, resource ...string) (ok bool) {
|
||||||
|
return a.store.Load() != nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AtomicAdapter) Get(ctx context.Context, pattern string) (value interface{}, err error) {
|
||||||
|
raw := a.store.Load()
|
||||||
|
if raw == nil {
|
||||||
|
return nil, errors.New("config not loaded")
|
||||||
|
}
|
||||||
|
data := raw.(map[string]interface{})
|
||||||
|
if v, ok := data[pattern]; ok {
|
||||||
|
return gvar.New(v), nil
|
||||||
|
}
|
||||||
|
return gvar.New(nil), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AtomicAdapter) Data(ctx context.Context) (data map[string]interface{}, err error) {
|
||||||
|
raw := a.store.Load()
|
||||||
|
if raw == nil {
|
||||||
|
return nil, errors.New("config not loaded")
|
||||||
|
}
|
||||||
|
original := raw.(map[string]interface{})
|
||||||
|
clone := make(map[string]interface{}, len(original))
|
||||||
|
for k, v := range original {
|
||||||
|
clone[k] = v
|
||||||
|
}
|
||||||
|
return clone, nil
|
||||||
|
}
|
||||||
50
apapter/context.go
Normal file
50
apapter/context.go
Normal file
@ -0,0 +1,50 @@
|
|||||||
|
package apapter
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
|
||||||
|
"github.com/gogf/gf/v2/container/gvar"
|
||||||
|
"github.com/gogf/gf/v2/encoding/gbase64"
|
||||||
|
"github.com/gogf/gf/v2/encoding/gjson"
|
||||||
|
"github.com/gogf/gf/v2/frame/g"
|
||||||
|
"google.golang.org/grpc/metadata"
|
||||||
|
)
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @Description: ContextAdapter
|
||||||
|
* @author dc.To
|
||||||
|
* @version 20250807
|
||||||
|
*/
|
||||||
|
type ContextAdapter struct {
|
||||||
|
ctx context.Context
|
||||||
|
adapter string
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewContextAdapter(ctx context.Context, adapter string) *ContextAdapter {
|
||||||
|
return &ContextAdapter{ctx: ctx, adapter: adapter}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *ContextAdapter) ctxWithConfig(ctx context.Context) *gvar.Var {
|
||||||
|
md, ok := metadata.FromIncomingContext(ctx)
|
||||||
|
if ok {
|
||||||
|
if c := md.Get(a.adapter); len(c) > 0 {
|
||||||
|
return gvar.New(gbase64.MustDecodeToString(c[0]))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
g.Log("cfg").Error(ctx, "No Metadata from ["+a.adapter+"] cfg context")
|
||||||
|
|
||||||
|
return gvar.New(nil)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *ContextAdapter) Available(ctx context.Context, resource ...string) (ok bool) {
|
||||||
|
return a.ctxWithConfig(ctx) != nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *ContextAdapter) Get(ctx context.Context, pattern string) (value interface{}, err error) {
|
||||||
|
|
||||||
|
return gjson.New(a.ctxWithConfig(ctx)).Get(pattern).Val(), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *ContextAdapter) Data(ctx context.Context) (data map[string]interface{}, err error) {
|
||||||
|
return gjson.New(a.ctxWithConfig(ctx)).Map(), nil
|
||||||
|
}
|
||||||
@ -4,9 +4,8 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/gogf/gf/v2/encoding/gbase64"
|
"git.blueorigin.work/blueorigin/invoke/apapter"
|
||||||
"github.com/gogf/gf/v2/frame/g"
|
"github.com/gogf/gf/v2/frame/g"
|
||||||
"github.com/gogf/gf/v2/os/gcfg"
|
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
"google.golang.org/grpc/metadata"
|
"google.golang.org/grpc/metadata"
|
||||||
)
|
)
|
||||||
@ -46,20 +45,16 @@ func ClientContextUnaryChain(ctx context.Context, req interface{}, info *grpc.Un
|
|||||||
* @version 20250418
|
* @version 20250418
|
||||||
*/
|
*/
|
||||||
func ClientMetadataUnaryChain(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
|
func ClientMetadataUnaryChain(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
|
||||||
|
|
||||||
md, ok := metadata.FromIncomingContext(ctx)
|
md, ok := metadata.FromIncomingContext(ctx)
|
||||||
if ok {
|
if ok {
|
||||||
for k, v := range md {
|
for k, v := range md {
|
||||||
if strings.HasPrefix(k, "x-cfg-") && len(v) > 0 {
|
if strings.HasPrefix(k, "x-cfg-") && len(v) > 0 {
|
||||||
c := strings.Join(v, "")
|
g.Cfg(strings.TrimPrefix(k, "x-cfg-")).SetAdapter(apapter.NewContextAdapter(ctx, k))
|
||||||
if len(c) > 0 {
|
|
||||||
adapter, err := gcfg.NewAdapterContent(gbase64.MustDecodeToString(v[0]))
|
|
||||||
if err != nil {
|
|
||||||
g.Log("unary").Error(ctx, err)
|
|
||||||
}
|
|
||||||
g.Cfg(strings.TrimPrefix(k, "x-cfg-")).SetAdapter(adapter)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
g.Log("unary").Error(ctx, "No Metadata from incoming cfg context")
|
||||||
}
|
}
|
||||||
return handler(ctx, req)
|
return handler(ctx, req)
|
||||||
}
|
}
|
||||||
|
|||||||
@ -4,20 +4,20 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
"git.linkiio.cn/linkpay/invoke/chain"
|
"git.blueorigin.work/blueorigin/invoke/chain"
|
||||||
"git.linkiio.cn/linkpay/protobuf"
|
"git.blueorigin.work/blueorigin/protobuf"
|
||||||
"github.com/gogf/gf/contrib/registry/etcd/v2"
|
"github.com/gogf/gf/contrib/registry/etcd/v2"
|
||||||
"github.com/gogf/gf/contrib/rpc/grpcx/v2"
|
"github.com/gogf/gf/contrib/rpc/grpcx/v2"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
"google.golang.org/grpc/reflection"
|
"google.golang.org/grpc/reflection"
|
||||||
)
|
)
|
||||||
|
|
||||||
var Endpoint = os.Getenv("ETCD_ENDPOINTS")
|
var Endpoints = os.Getenv("ETCD_ENDPOINTS")
|
||||||
|
|
||||||
var GrpcConfig *grpcx.GrpcServerConfig = grpcx.Server.NewConfig()
|
var GrpcConfig *grpcx.GrpcServerConfig = grpcx.Server.NewConfig()
|
||||||
|
|
||||||
func Etcd() *etcd.Registry {
|
func Etcd() *etcd.Registry {
|
||||||
return etcd.New(Endpoint)
|
return etcd.New(Endpoints)
|
||||||
}
|
}
|
||||||
|
|
||||||
func SetOptions(o ...grpc.ServerOption) *grpcx.GrpcServerConfig {
|
func SetOptions(o ...grpc.ServerOption) *grpcx.GrpcServerConfig {
|
||||||
@ -40,7 +40,7 @@ func Registry(f ...func(s *grpcx.GrpcServer)) *grpcx.GrpcServer {
|
|||||||
chain.ClientMetadataUnaryChain,
|
chain.ClientMetadataUnaryChain,
|
||||||
)}...,
|
)}...,
|
||||||
)
|
)
|
||||||
if Endpoint != "" {
|
if Endpoints != "" {
|
||||||
grpcx.Resolver.Register(Etcd())
|
grpcx.Resolver.Register(Etcd())
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -65,7 +65,7 @@ func Registry(f ...func(s *grpcx.GrpcServer)) *grpcx.GrpcServer {
|
|||||||
* @version 20250427
|
* @version 20250427
|
||||||
*/
|
*/
|
||||||
func Reflect(s reflection.GRPCServer, f ...func()) {
|
func Reflect(s reflection.GRPCServer, f ...func()) {
|
||||||
if Endpoint == "" {
|
if Endpoints == "" {
|
||||||
reflection.Register(s)
|
reflection.Register(s)
|
||||||
}
|
}
|
||||||
for _, fn := range f {
|
for _, fn := range f {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user