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 RpcClientContainer
  • func (i *RpcClientContainer) Get(name string) any
  • func (i *RpcClientContainer) Is(instance any) bool
  • func (i *RpcClientContainer) Range() chan 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) Load()
• type RpcConf
  • func (i *RpcConf) ConfigName() string
  • func (i *RpcConf) GetHost(pkg, app, name string) (host string)
  • func (i *RpcConf) Init()
• type RpcConf_Client
• type RpcConf_Client_Service
• type RpcServiceContainer
  • func (i *RpcServiceContainer) Get(name string) any
  • func (i *RpcServiceContainer) Is(instance any) bool
  • func (i *RpcServiceContainer) Range() chan any
  • func (i *RpcServiceContainer) Remove(name string) bool
  • func (i *RpcServiceContainer) Save(instance any) bool
• type RpcServiceInterface

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 RpcClientContainer

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

func (*RpcClientContainer) Get

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

func (*RpcClientContainer) Is

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

func (*RpcClientContainer) Range

func (i *RpcClientContainer) Range() chan 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) 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"`
	// contains filtered or unexported fields
}

func (*RpcConf) ConfigName

func (i *RpcConf) ConfigName() string

func (*RpcConf) GetHost

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

func (*RpcConf) Init

func (i *RpcConf) Init()

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