cRpc

Documentation

Index

• Constants
• Variables
• func Decrypt(f DecryptFunc)
• func Encrypt(f EncryptFunc)
• func GRPCRequest[C any](ctx *gin.Context, client RpcClientInterface, ...) (rsp any, err error)
• func GetService(app, service string) any
• func HTTPRequest(ctx *gin.Context, client RpcClientInterface, method string, req, rsp any) (err error)
• func Inject(instance any)
• func InjectConf(conf any)
• func IsRpcService(instance any) bool
• func ListenConf(instance any)
• func Load()
• func SetHostFunc(hostFunc ParseHostFunc)
• type ClientType
• type DecryptFunc
• type EncryptFunc
• type ParseHostFunc
• type RpcClientContainer
  • func (i *RpcClientContainer) GetGrpcConn(pkg, app, service string) (conn grpc.ClientConnInterface, err error)
  • func (i *RpcClientContainer) GetHost(pkg, app, service string) string
  • func (i *RpcClientContainer) Save(client *RpcConf_Client)
  • func (i *RpcClientContainer) SetEncrypt(f EncryptFunc)
  • func (i *RpcClientContainer) SetHostFunc(hostFunc ParseHostFunc)
  • func (i *RpcClientContainer) SetSignature(key string)
• type RpcClientInterface
• type RpcComponent
  • func (k *RpcComponent) Inject(instance any)
  • func (k *RpcComponent) ListenConf() map[string]cComponents.ListenConfigFunc
  • func (k *RpcComponent) Load()
• type RpcConf
  • func GetConf() *RpcConf
  • func (i *RpcConf) ConfigName() string
• type RpcConf_Client
• type RpcConf_Client_Service
• type RpcContainer
  • func (i *RpcContainer) Get(app, service string) any
  • func (i *RpcContainer) Save(instance any)
  • func (i *RpcContainer) SetDecrypt(f DecryptFunc)
• type RpcController
  • func (c *RpcController) ControllerName() (app, name string)
  • func (c *RpcController) Handler(ctx *gin.Context) (err error)
• type RpcServiceInterface

Constants

const (
	ConfigName = "RpcConf"
)

Variables

var Component = &RpcComponent{}

Functions

func Decrypt

func Decrypt(f DecryptFunc)

func Encrypt

func Encrypt(f EncryptFunc)

func GRPCRequest

func GRPCRequest[C any](ctx *gin.Context, client RpcClientInterface, f func(cc grpc.ClientConnInterface) C, method string, req any) (rsp any, err error)

func GetService

func GetService(app, service string) any

func HTTPRequest

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

func Inject

func Inject(instance any)

func InjectConf

func InjectConf(conf any)

func IsRpcService

func IsRpcService(instance any) bool

func ListenConf

func ListenConf(instance any)

func Load

func Load()

func SetHostFunc

func SetHostFunc(hostFunc ParseHostFunc)

Types

type ClientType

type ClientType string

const (
	GRPCClient ClientType = "grpc"
	HTTPClient ClientType = "http"
)

type DecryptFunc

type DecryptFunc func(ctx *gin.Context) bool

type EncryptFunc

type EncryptFunc func(ctx *gin.Context) string

type ParseHostFunc

type ParseHostFunc func(ctx *gin.Context, app, service string) (host, uri string) // 自定义路由策略

type RpcClientContainer

type RpcClientContainer struct {
	Lock        *sync.Mutex
	Signature   string
	Hosts       map[string]string
	HostFunc    ParseHostFunc
	EncryptFunc EncryptFunc
	GrpcConn    map[string]grpc.ClientConnInterface
}

func (*RpcClientContainer) GetGrpcConn

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

func (*RpcClientContainer) GetHost

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

func (*RpcClientContainer) Save

func (i *RpcClientContainer) Save(client *RpcConf_Client)

func (*RpcClientContainer) SetEncrypt

func (i *RpcClientContainer) SetEncrypt(f EncryptFunc)

func (*RpcClientContainer) SetHostFunc

func (i *RpcClientContainer) SetHostFunc(hostFunc ParseHostFunc)

func (*RpcClientContainer) SetSignature

func (i *RpcClientContainer) SetSignature(key string)

type RpcClientInterface

type RpcClientInterface interface {
	RpcClientName() (pkg, app, service string)
}

type RpcComponent

type RpcComponent struct{}

func (*RpcComponent) Inject

func (k *RpcComponent) Inject(instance any)

func (*RpcComponent) ListenConf

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

func (*RpcComponent) Load

func (k *RpcComponent) Load()

type RpcConf

type RpcConf struct {
	RequestURI string            `json:"request_uri"`
	Timeout    int64             `json:"timeout"`
	Try        int64             `json:"try"`
	Signature  string            `json:"signature"`
	Clients    []*RpcConf_Client `json:"clients"`
}

func GetConf

func GetConf() *RpcConf

func (*RpcConf) ConfigName

func (i *RpcConf) ConfigName() string

type RpcConf_Client

type RpcConf_Client struct {
	Type     ClientType                `json:"type"`
	Host     string                    `json:"host"`
	Package  string                    `json:"package"`
	Services []*RpcConf_Client_Service `json:"services"`
}

type RpcConf_Client_Service

type RpcConf_Client_Service struct {
	App     string `json:"app"`
	Service string `json:"service"`
}

type RpcContainer

type RpcContainer struct {
	Lock        *sync.Mutex
	DecryptFunc DecryptFunc
	Instances   map[string]any
}

func (*RpcContainer) Get

func (i *RpcContainer) Get(app, service string) any

func (*RpcContainer) Save

func (i *RpcContainer) Save(instance any)

func (*RpcContainer) SetDecrypt

func (i *RpcContainer) SetDecrypt(f DecryptFunc)

type RpcController

type RpcController struct {
}

func (*RpcController) ControllerName

func (c *RpcController) ControllerName() (app, name string)

func (*RpcController) Handler

func (c *RpcController) Handler(ctx *gin.Context) (err error)

type RpcServiceInterface

type RpcServiceInterface interface {
	RpcServiceName() (app, service string)
}