Versions in this module Expand all Collapse all v1 v1.2.1 Mar 15, 2020 Changes in this version + var RPC_PARAM_ProtocolMarshal_TYPE = gate.RPC_PARAM_ProtocolMarshal_TYPE + var RPC_PARAM_SESSION_TYPE = gate.RPC_PARAM_SESSION_TYPE + func NewGateHandler(gate gate.Gate) *handler + func NewMqttAgent(module module.RPCModule) *agent + func NewSession(app module.App, data []byte) (gate.Session, error) + func NewSessionByMap(app module.App, data map[string]interface{}) (gate.Session, error) + type Gate struct + CertFile string + HTTPTimeout time.Duration + KeyFile string + TCPAddr string + Tls bool + WSAddr string + func (this *Gate) Deserialize(ptype string, b []byte) (param interface{}, err error) + func (this *Gate) GetAgentLearner() gate.AgentLearner + func (this *Gate) GetGateHandler() gate.GateHandler + func (this *Gate) GetJudgeGuest() func(session gate.Session) bool + func (this *Gate) GetModule() module.RPCModule + func (this *Gate) GetRouteHandler() gate.RouteHandler + func (this *Gate) GetSessionLearner() gate.SessionLearner + func (this *Gate) GetStorageHandler() (storage gate.StorageHandler) + func (this *Gate) GetTypes() []string + func (this *Gate) NewSession(data []byte) (gate.Session, error) + func (this *Gate) NewSessionByMap(data map[string]interface{}) (gate.Session, error) + func (this *Gate) OnAppConfigurationLoaded(app module.App) + func (this *Gate) OnConfChanged(settings *conf.ModuleSettings) + func (this *Gate) OnDestroy() + func (this *Gate) OnInit(subclass module.RPCModule, app module.App, settings *conf.ModuleSettings, ...) + func (this *Gate) Options() gate.Options + func (this *Gate) Run(closeSig chan bool) + func (this *Gate) Serialize(param interface{}) (ptype string, p []byte, err error) + func (this *Gate) SetCreateAgent(cfunc func() gate.Agent) error + func (this *Gate) SetJudgeGuest(judgeGuest func(session gate.Session) bool) error + func (this *Gate) SetRouteHandler(router gate.RouteHandler) error + func (this *Gate) SetSessionLearner(sessionLearner gate.SessionLearner) error + func (this *Gate) SetStorageHandler(storage gate.StorageHandler) error + type SessionImp struct + Carrier map[string]string + IP string + Network string + ServerId string + SessionId string + Settings map[string]string + SpanId string + Topic string + TraceId string + UserId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SessionImp) Descriptor() ([]byte, []int) + func (*SessionImp) ProtoMessage() + func (m *SessionImp) GetCarrier() map[string]string + func (m *SessionImp) GetIP() string + func (m *SessionImp) GetNetwork() string + func (m *SessionImp) GetServerId() string + func (m *SessionImp) GetSessionId() string + func (m *SessionImp) GetSettings() map[string]string + func (m *SessionImp) GetSpanId() string + func (m *SessionImp) GetTopic() string + func (m *SessionImp) GetTraceId() string + func (m *SessionImp) GetUserId() string + func (m *SessionImp) Reset() + func (m *SessionImp) String() string + func (m *SessionImp) XXX_DiscardUnknown() + func (m *SessionImp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SessionImp) XXX_Merge(src proto.Message) + func (m *SessionImp) XXX_Size() int + func (m *SessionImp) XXX_Unmarshal(b []byte) error
Go to main page