info

Documentation

Index

• func GetClaimRequestChannel(service, clientID string) string
• func GetResponseChannel(service, clientID string) string
• func GetStreamChannel(service, nodeID string) string
• type MethodInfo
• type RequestInfo
  • func (i *RequestInfo) GetClaimResponseChannel() string
  • func (i *RequestInfo) GetHandlerKey() string
  • func (i *RequestInfo) GetRPCChannel() string
  • func (i *RequestInfo) GetStreamServerChannel() string
• type ServiceDefinition
  • func (s *ServiceDefinition) GetInfo(rpc string, topic []string) *RequestInfo
  • func (s *ServiceDefinition) RegisterMethod(name string, affinityEnabled, multi, requireClaim, queue bool)

Functions

func GetClaimRequestChannel

func GetClaimRequestChannel(service, clientID string) string

func GetResponseChannel

func GetResponseChannel(service, clientID string) string

func GetStreamChannel

func GetStreamChannel(service, nodeID string) string

Types

type MethodInfo

type MethodInfo struct {
	AffinityEnabled bool
	Multi           bool
	RequireClaim    bool
	Queue           bool
}

type RequestInfo

type RequestInfo struct {
	psrpc.RPCInfo
	AffinityEnabled bool
	RequireClaim    bool
	Queue           bool
}

func (*RequestInfo) GetClaimResponseChannel

func (i *RequestInfo) GetClaimResponseChannel() string

func (*RequestInfo) GetHandlerKey

func (i *RequestInfo) GetHandlerKey() string

func (*RequestInfo) GetRPCChannel

func (i *RequestInfo) GetRPCChannel() string

func (*RequestInfo) GetStreamServerChannel

func (i *RequestInfo) GetStreamServerChannel() string

type ServiceDefinition

type ServiceDefinition struct {
	Name    string
	ID      string
	Methods sync.Map
}

func (*ServiceDefinition) GetInfo

func (s *ServiceDefinition) GetInfo(rpc string, topic []string) *RequestInfo

func (*ServiceDefinition) RegisterMethod

func (s *ServiceDefinition) RegisterMethod(name string, affinityEnabled, multi, requireClaim, queue bool)