cRpc

Feb 22, 2024

Changes in this version

+ const HTTPRequestUri

+ const HTTPTimeout

+ const HTTPTryTimes

+ const RpcConfigName

type RpcClientContainer

+ func (i *RpcClientContainer) GetGRPCConnection(pkg, app, name string) grpc.ClientConnInterface

+ func (i *RpcClientContainer) Is(instance any) bool

+ func (i *RpcClientContainer) Range(f func(instance any))

+ func (i *RpcClientContainer) Remove(name string) bool

type RpcComponent

+ func (i *RpcComponent) InjectConf(config cComponents.ConfigInterface) bool

+ func (i *RpcComponent) Listen() []*cComponents.ConfigListener

type RpcConf

+ HostFunc ParseHostFunc

+ SignDecryptFunc SignatureDecryptFunc

+ SignEncryptFunc SignatureEncryptFunc

+ func (i *RpcConf) Init()

+ func (i *RpcConf) SetHostFunc(f ParseHostFunc)

+ func (i *RpcConf) SetSignDecryptFunc(f SignatureDecryptFunc)

+ func (i *RpcConf) SetSignEncryptFunc(f SignatureEncryptFunc)

+ type RpcServiceContainer struct

+ func (i *RpcServiceContainer) Get(name string) any

+ func (i *RpcServiceContainer) Is(instance any) bool

+ func (i *RpcServiceContainer) Range(f func(instance any))

+ func (i *RpcServiceContainer) Remove(name string) bool

+ func (i *RpcServiceContainer) Save(instance any) bool

+ type SignatureDecryptFunc func(ctx *gin.Context, app, service string) bool

+ type SignatureEncryptFunc func(ctx *gin.Context, app, service string) string

Feb 4, 2024

Changes in this version

+ const ConfigName

+ var Component = &RpcComponent

+ func ListenConf(instance any)

+ type RpcComponent struct

+ func (k *RpcComponent) Inject(instance any)

+ func (k *RpcComponent) ListenConf() map[string]cComponents.ListenConfigFunc

+ func (k *RpcComponent) Load()

type RpcConf

+ func GetConf() *RpcConf

Jan 24, 2024

Changes in this version

+ func GRPCRequest[C any](ctx *gin.Context, client RpcClientInterface, ...) (err error)

+ func HTTPRequest(ctx *gin.Context, client RpcClientInterface, method string, ...) (err error)

Dec 15, 2023

Changes in this version

+ type ClientType string

+ const GRPCClient

+ const HTTPClient

type RpcConf_Client

+ Type ClientType

Dec 14, 2023

Changes in this version

+ func GetGrpcClient[C any](ctx *gin.Context, instance RpcClientInterface, ...) (client C, err error)

type RpcClientContainer

+ GrpcConn map[string]grpc.ClientConnInterface

+ func (i *RpcClientContainer) GetGrpcConn(pkg, app, service string) (conn grpc.ClientConnInterface, err error)

Jul 31, 2023

Changes in this version

+ func SetCheckFunc(f CheckFunc)

Dec 14, 2023

Changes in this version

+ func Decrypt(f DecryptFunc)

+ func Encrypt(f EncryptFunc)

+ func GrpcHandler[Q, T any](ctx context.Context, app, service, method string, req Q, rsp T) (err error)

+ func InjectConf(conf interface{})

+ func SetHostFunc(hostFunc ParseHostFunc)

+ type DecryptFunc func(ctx *gin.Context) bool

+ type EncryptFunc func(ctx *gin.Context) string

+ type ParseHostFunc func(ctx *gin.Context, app, service string) (host, uri string)

type RpcClientContainer

+ EncryptFunc EncryptFunc

+ HostFunc ParseHostFunc

+ Signature string

+ func (i *RpcClientContainer) SetEncrypt(f EncryptFunc)

+ func (i *RpcClientContainer) SetHostFunc(hostFunc ParseHostFunc)

+ func (i *RpcClientContainer) SetSignature(key string)

type RpcConf

+ Signature string

+ Timeout int64

+ Try int64

+ func GetRpcConf() *RpcConf

type RpcConf_Client

+ Package string

type RpcContainer

+ DecryptFunc DecryptFunc

+ func (i *RpcContainer) SetDecrypt(f DecryptFunc)

Jul 12, 2022

Changes in this version

type RpcConf

+ RequestURI string

Apr 25, 2022

Changes in this version

type RpcController

+ func (i *RpcController) Handler(ctx *gin.Context) (int, interface{})

Apr 25, 2022

Changes in this version

type RpcConf

+ Clients []*RpcConf_Client

+ type RpcConf_Client struct

+ Host string

+ Services []*RpcConf_Client_Service

+ type RpcConf_Client_Service struct

+ App string

+ Service string

Apr 25, 2022

Changes in this version

type RpcClientContainer

+ Hosts map[string]string

+ func (i *RpcClientContainer) GetHost(app, service string) string

Apr 16, 2022

Changes in this version

+ const Header_Rpc_App

+ const Header_Rpc_Method

+ const Header_Rpc_Service

+ func Call(ctx *gin.Context, client, method string, req, rsp interface{}) (err error)

+ func GetGinHandlerFunc() gin.HandlerFunc

+ func GetService(app, service string) interface

+ func Inject(instance interface{})

+ func IsRpcService(instance interface{}) bool

+ func Load()

+ type RpcClientContainer struct

+ Instances map[string]*RpcConf_Service

+ Lock *sync.Mutex

+ func (i *RpcClientContainer) Get(client string) (host, app, service string, err error)

+ func (i *RpcClientContainer) Save(client string, conf *RpcConf_Service)

+ type RpcClientInterface interface

+ RpcClientName func() string

+ type RpcConf struct

+ Services []*RpcConf_Service

+ func (i *RpcConf) ConfigName() string

+ type RpcConf_Service struct

+ App string

+ Client string

+ Host string

+ Service string

+ type RpcContainer struct

+ Instances map[string]interface{}

+ Lock *sync.Mutex

+ func (i *RpcContainer) Get(app, service string) interface{}

+ func (i *RpcContainer) Handler(ctx *gin.Context) (int, interface{})

+ func (i *RpcContainer) Save(instance interface{})

+ type RpcController struct

+ func (c *RpcController) ControllerName() string

+ type RpcServiceInterface interface

+ RpcServiceName func() (string, string)