cRpc

Documentation

Index

• Constants
• Variables
• func GRPCRequest[C any](ctx *gin.Context, client RpcClientInterface, ...) (rsp any, err error)
• func HTTPRequest(ctx *gin.Context, client RpcClientInterface, method string, req, rsp any) (err error)
• type ClientType
• type ParseHostFunc
• type RpcClientContainer
  • func (i *RpcClientContainer) Get(name string) any
  • func (i *RpcClientContainer) GetGRPCConnection(pkg, app, name string) grpc.ClientConnInterface
  • func (i *RpcClientContainer) GetHost(pkg, app, name string) (host string)
  • func (i *RpcClientContainer) Is(instance any) bool
  • func (i *RpcClientContainer) Range(f func(instance any))
  • func (i *RpcClientContainer) Remove(name string) bool
  • func (i *RpcClientContainer) Save(instance any) bool
• type RpcClientInterface
• type RpcComponent
  • func (i *RpcComponent) Inject(instance any) bool
  • func (i *RpcComponent) InjectConf(config cComponents.ConfigInterface) bool
  • func (i *RpcComponent) Listen() []*cComponents.ConfigListener
  • func (i *RpcComponent) Load()
• type RpcConf
  • func (i *RpcConf) ConfigName() string
  • func (i *RpcConf) Init()
  • func (i *RpcConf) SetHostFunc(f ParseHostFunc)
  • func (i *RpcConf) SetSignDecryptFunc(f SignatureDecryptFunc)
  • func (i *RpcConf) SetSignEncryptFunc(f SignatureEncryptFunc)
• type RpcConf_Client
• type RpcConf_Client_Service
• type RpcController
  • func (i *RpcController) ControllerName() (app, name string)
  • func (i *RpcController) Handler(ctx *gin.Context) (err error)
• type RpcServiceContainer
  • 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 RpcServiceInterface
• type SignatureDecryptFunc
• type SignatureEncryptFunc

Constants

const (
	RpcConfigName string = "RpcConf"

	GRPCClient ClientType = "grpc"
	HTTPClient ClientType = "http"

	HTTPRequestUri string = "/rpc/call"
	HTTPTimeout    int64  = 60
	HTTPTryTimes   int64  = 3
)

Variables

var Component = &RpcComponent{}

Functions

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 HTTPRequest

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

Types

type ClientType

type ClientType string

type ParseHostFunc

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

type RpcClientContainer

type RpcClientContainer struct {
	// contains filtered or unexported fields
}

func (*RpcClientContainer) Get

func (i *RpcClientContainer) Get(name string) any

func (*RpcClientContainer) GetGRPCConnection

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

func (*RpcClientContainer) GetHost

func (i *RpcClientContainer) GetHost(pkg, app, name string) (host string)

func (*RpcClientContainer) Is

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

func (*RpcClientContainer) Range

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

func (*RpcClientContainer) Remove

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

func (*RpcClientContainer) Save

func (i *RpcClientContainer) Save(instance any) bool

type RpcClientInterface

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

type RpcComponent

type RpcComponent struct{}

func (*RpcComponent) Inject

func (i *RpcComponent) Inject(instance any) bool

func (*RpcComponent) InjectConf

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

func (*RpcComponent) Listen

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

func (*RpcComponent) Load

func (i *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"`
	HostFunc        ParseHostFunc        `json:"-"`
	SignEncryptFunc SignatureEncryptFunc `json:"-"`
	SignDecryptFunc SignatureDecryptFunc `json:"-"`
}

func (*RpcConf) ConfigName

func (i *RpcConf) ConfigName() string

func (*RpcConf) Init

func (i *RpcConf) Init()

func (*RpcConf) SetHostFunc

func (i *RpcConf) SetHostFunc(f ParseHostFunc)

func (*RpcConf) SetSignDecryptFunc

func (i *RpcConf) SetSignDecryptFunc(f SignatureDecryptFunc)

func (*RpcConf) SetSignEncryptFunc

func (i *RpcConf) SetSignEncryptFunc(f SignatureEncryptFunc)

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 RpcController

type RpcController struct{}

func (*RpcController) ControllerName

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

func (*RpcController) Handler

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

type RpcServiceContainer

type RpcServiceContainer struct {
	// contains filtered or unexported fields
}

func (*RpcServiceContainer) Get

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

func (*RpcServiceContainer) Is

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

func (*RpcServiceContainer) Range

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

func (*RpcServiceContainer) Remove

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

func (*RpcServiceContainer) Save

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

type RpcServiceInterface

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

type SignatureDecryptFunc

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

type SignatureEncryptFunc

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