Versions in this module Expand all Collapse all v1 v1.6.7 Feb 27, 2018 Changes in this version + type Agent interface + Close func() + Destroy func() + GetSession func() Session + IsClosed func() bool + OnClose func() error + OnInit func(gate Gate, conn network.Conn) error + RevNum func() int64 + Run func() (err error) + SendNum func() int64 + WriteMsg func(topic string, body []byte) error + type AgentLearner interface + Connect func(a Agent) + DisConnect func(a Agent) + type Gate interface + GetAgentLearner func() AgentLearner + GetGateHandler func() GateHandler + GetMinStorageHeartbeat func() int64 + GetSessionLearner func() SessionLearner + GetStorageHandler func() StorageHandler + GetTracingHandler func() TracingHandler + NewSession func(data []byte) (Session, error) + NewSessionByMap func(data map[string]interface{}) (Session, error) + type GateHandler interface + Bind func(Sessionid string, Userid string) (result Session, err string) + BroadCast func(topic string, body []byte) (int64, string) + Close func(Sessionid string) (result interface{}, err string) + IsConnect func(Sessionid string, Userid string) (result bool, err string) + OnDestroy func() + Push func(Sessionid string, Settings map[string]string) (result Session, err string) + Remove func(Sessionid string, key string) (result interface{}, err string) + Send func(Sessionid string, topic string, body []byte) (result interface{}, err string) + SendBatch func(Sessionids string, topic string, body []byte) (int64, string) + Set func(Sessionid string, key string, value string) (result Session, err string) + UnBind func(Sessionid string) (result Session, err string) + Update func(Sessionid string) (result Session, err string) + type Session interface + Bind func(Userid string) (err string) + Clone func() Session + Close func() (err string) + CreateRootSpan func(operationName string) opentracing.Span + ExtractSpan func(operationName string) opentracing.Span + Get func(key string) (result string) + GetIP func() string + GetNetwork func() string + GetServerid func() string + GetSessionid func() string + GetSettings func() map[string]string + GetUserid func() string + IsConnect func(Userid string) (result bool, err string) + IsGuest func() bool + JudgeGuest func(judgeGuest func(session Session) bool) + LoadSpan func(operationName string) opentracing.Span + Push func() (err string) + Remove func(key string) (err string) + Send func(topic string, body []byte) (err string) + SendBatch func(Sessionids string, topic string, body []byte) (int64, string) + SendNR func(topic string, body []byte) (err string) + Serializable func() ([]byte, error) + Set func(key string, value string) (err string) + SetIP func(ip string) + SetNetwork func(network string) + SetPush func(key string, value string) (err string) + SetServerid func(serverid string) + SetSessionid func(sessionid string) + SetSettings func(settings map[string]string) + SetUserid func(userid string) + Span func() opentracing.Span + TracCarrier func() map[string]string + TracId func() string + UnBind func() (err string) + Update func() (err string) + type SessionLearner interface + Connect func(a Session) + DisConnect func(a Session) + type StorageHandler interface + Delete func(Userid string) (err error) + Heartbeat func(Userid string) + Query func(Userid string) (data []byte, err error) + Storage func(Userid string, session Session) (err error) + type TracingHandler interface + OnRequestTracing func(session Session, topic string, msg []byte) bool
Go to main page