cRpc

Documentation

Index

• 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 InjectConf(conf interface{})
• func IsRpcService(instance interface{}) bool
• func Load()
• type RpcClientContainer
  • func (i *RpcClientContainer) GetHost(app, service string) string
  • func (i *RpcClientContainer) Save(client *RpcConf_Client)
• 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{})
• type RpcController
  • func (c *RpcController) ControllerName() (app, name string)
  • func (c *RpcController) Handler(ctx *gin.Context) (int, interface{})
• type RpcServiceInterface

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 InjectConf

func InjectConf(conf 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(client *RpcConf_Client)

type RpcClientInterface

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

type RpcConf

type RpcConf struct {
	RequestURI string            `json:"request_uri"`
	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 {
	Host     string                    `json:"host"`
	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
	Instances map[string]interface{}
}

func (*RpcContainer) Get

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

func (*RpcContainer) Save

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

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) (int, interface{})

type RpcServiceInterface

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