cRpc

Documentation

Index

• Constants
• func Call(ctx *gin.Context, client RpcClientInterface, method string, ...) (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
  • func (i *RpcClientContainer) GetHost(app, service string) string
  • func (i *RpcClientContainer) Save(service *RpcConf_Service)
• type RpcClientInterface
• type RpcConf
  • func (i *RpcConf) ConfigName() string
• type RpcConf_Service
• type RpcContainer
  • 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
  • func (c *RpcController) ControllerName() string
• type RpcServiceInterface

Constants

const (
	Header_Rpc_App     = "Rpc-App"
	Header_Rpc_Service = "Rpc-Service"
	Header_Rpc_Method  = "Rpc-Method"
)

Functions

func Call

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

func GetGinHandlerFunc

func GetGinHandlerFunc() gin.HandlerFunc

func GetService

func GetService(app, service string) interface{}

func Inject

func Inject(instance interface{})

func IsRpcService

func IsRpcService(instance interface{}) bool

func Load

func Load()

Types

type RpcClientContainer

type RpcClientContainer struct {
	Lock  *sync.Mutex
	Hosts map[string]string
}

func (*RpcClientContainer) GetHost

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

func (*RpcClientContainer) Save

func (i *RpcClientContainer) Save(service *RpcConf_Service)

type RpcClientInterface

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

type RpcConf

type RpcConf struct {
	Services []*RpcConf_Service `json:"services"`
}

func (*RpcConf) ConfigName

func (i *RpcConf) ConfigName() string

type RpcConf_Service

type RpcConf_Service struct {
	Host    string `json:"host"`
	App     string `json:"app"`
	Service string `json:"service"`
}

type RpcContainer

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

func (*RpcContainer) Get

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

func (*RpcContainer) Handler

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

func (*RpcContainer) Save

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

type RpcController

type RpcController struct {
}

func (*RpcController) ControllerName

func (c *RpcController) ControllerName() string

type RpcServiceInterface

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