cRpc

Documentation

Index

• func Decrypt(f DecryptFunc)
• func Encrypt(f EncryptFunc)
• func GRPCRequest[C any](ctx *gin.Context, client RpcClientInterface, ...) (rsp interface{}, err error)
• func GetService(app, service string) interface{}
• func HTTPRequest(ctx *gin.Context, client RpcClientInterface, method string, ...) (err error)
• func Inject(instance interface{})
• func InjectConf(conf interface{})
• func IsRpcService(instance interface{}) bool
• 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 RpcConf
  • func GetRpcConf() *RpcConf
  • func (i *RpcConf) ConfigName() string
• type RpcConf_Client
• type RpcConf_Client_Service
• type RpcContainer
  • func (i *RpcContainer) Get(app, service string) interface{}
  • func (i *RpcContainer) Save(instance interface{})
  • 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

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 interface{}) (rsp interface{}, err error)

func GetService

func GetService(app, service string) interface{}

func HTTPRequest

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

func Inject

func Inject(instance interface{})

func InjectConf

func InjectConf(conf interface{})

func IsRpcService

func IsRpcService(instance interface{}) bool

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 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 GetRpcConf

func GetRpcConf() *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]interface{}
}

func (*RpcContainer) Get

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

func (*RpcContainer) Save

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

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)
}