hredisrouter

Documentation

Index

• Constants
• type RedisRouter
• type Router
  • func New() *Router
  • func (this *Router) Config() core.IEntityConf
  • func (this *Router) EntityStub() *core.EntityStub
  • func (this *Router) HandleServiceRequested(_ context.Context, args *core.RpcRequestArguments, resp *core.SlotResponse) error
  • func (this *Router) Open(s core.IServer, ins core.IRouter) *herrors.Error
  • func (this *Router) RegisterService(s core.IService) *herrors.Error
  • func (this *Router) RequestService(service string, slot string, params htypes.Map) (htypes.Any, *herrors.Error)
  • func (this *Router) UnRegisterService(s core.IService)

Constants

const (
	RpcxServer = "HasServices"
)

Types

type RedisRouter

type RedisRouter struct {
	core.EntityConfBase

	RedisServers  []string //如果cluster=false，使用第一个
	RedisUserName string
	RedisPassword string
	Database      int
	RpcxAddr      string
	Domain        string
	Cluster       bool
}

type Router

type Router struct {
	core.BaseRouter
	// contains filtered or unexported fields
}

func New

func New() *Router

func (*Router) Config

func (this *Router) Config() core.IEntityConf

func (*Router) EntityStub

func (this *Router) EntityStub() *core.EntityStub

func (*Router) HandleServiceRequested

func (this *Router) HandleServiceRequested(_ context.Context, args *core.RpcRequestArguments, resp *core.SlotResponse) error

func (*Router) Open

func (this *Router) Open(s core.IServer, ins core.IRouter) *herrors.Error

func (*Router) RegisterService

func (this *Router) RegisterService(s core.IService) *herrors.Error

func (*Router) RequestService

func (this *Router) RequestService(service string, slot string, params htypes.Map) (htypes.Any, *herrors.Error)

func (*Router) UnRegisterService

func (this *Router) UnRegisterService(s core.IService)