cellnet

Apr 2, 2020

Changes in this version

type TCPAcceptor

+ Port func() int

type TCPConnector

+ Port func() int

type WSAcceptor

+ Port func() int

+ SetUpgrader func(upgrader interface{})

Apr 2, 2020

Changes in this version

+ type CapturePanicNotifyFunc func(interface{}, EventQueue)

type ContextSet

+ FetchContext func(key, valuePtr interface{}) bool

+ type HTTPRequest struct

+ ACKCodecName string

+ ACKMsg interface{}

+ REQCodecName string

+ REQMsg interface{}

type MessageMeta

+ func (self *MessageMeta) GetContextAsInt(name string, defaultValue int) int

+ func (self *MessageMeta) GetContextAsString(key, defaultValue string) string

+ type MySQLConnector interface

+ ReconnectDuration func() time.Duration

+ SetConnectionCount func(v int)

+ SetPassword func(v string)

+ SetReconnectDuration func(v time.Duration)

+ type MySQLOperator interface

+ Operate func(callback func(rawClient interface{}) interface{}) interface{}

+ type PeerCaptureIOPanic interface

+ CaptureIOPanic func() bool

+ EnableCaptureIOPanic func(v bool)

+ type PeerReadyChecker interface

+ IsReady func() bool

+ type Pipe struct

+ func NewPipe() *Pipe

+ func (self *Pipe) Add(msg interface{})

+ func (self *Pipe) Pick(retList *[]interface{}) (exit bool)

+ func (self *Pipe) Reset()

type RecvMsgEvent

+ func (self *RecvMsgEvent) Reply(msg interface{})

+ type RedisConnector interface

+ SetConnectionCount func(v int)

+ SetDBIndex func(v int)

+ SetPassword func(v string)

+ type RedisPoolOperator interface

+ Operate func(callback func(rawClient interface{}) interface{}) interface{}

+ type ReplyEvent interface

+ Reply func(msg interface{})

+ type SystemMessageIdentifier interface

+ SystemMessage func()

+ type WSConnector interface

+ Port func() int

+ ReconnectDuration func() time.Duration

+ Session func() Session

+ SetReconnectDuration func(time.Duration)

+ SetSessionManager func(raw interface{})

Mar 25, 2020

Changes in this version

+ const DefaultQueueSize

+ func MessageMetaVisit(nameRule string, callback func(meta *MessageMeta) bool) error

+ func MessageSize(msg interface{}) int

+ func MessageToID(msg interface{}) int

+ func MessageToName(msg interface{}) string

+ func MessageToString(msg interface{}) string

+ func NewError(s string) error

+ func NewErrorContext(s string, context interface{}) error

+ func QueuedCall(queue EventQueue, callback func())

+ func RegisterHttpMeta(meta *HttpMeta)

+ func SessionQueuedCall(ses Session, callback func())

+ type CloseReason int32

+ const CloseReason_IO

+ const CloseReason_Manual

+ func (self CloseReason) String() string

+ type Codec interface

+ Decode func(data interface{}, msgObj interface{}) error

+ Encode func(msgObj interface{}, ctx ContextSet) (data interface{}, err error)

+ MimeType func() string

+ Name func() string

+ type ContextSet interface

+ GetContext func(key, valuePtr interface{}) bool

+ RawGetContext func(key interface{}) (interface{}, bool)

+ SetContext func(key interface{}, v interface{})

+ type Error struct

+ func (self *Error) Error() string

+ type Event interface

+ Message func() interface{}

+ Session func() Session

+ type EventCallback func(ev Event)

+ type EventHooker interface

+ OnInboundEvent func(input Event) (output Event)

+ OnOutboundEvent func(input Event) (output Event)

+ type EventQueue interface

+ EnableCapturePanic func(v bool)

+ Post func(callback func())

+ StartLoop func() EventQueue

+ StopLoop func() EventQueue

+ Wait func()

+ func NewEventQueue() EventQueue

+ type GenericPeer interface

+ type HTTPAcceptor interface

+ SetFileServe func(dir string, root string)

+ SetTemplateDelims func(delimsLeft, delimsRight string)

+ SetTemplateDir func(dir string)

+ SetTemplateExtensions func(exts []string)

+ SetTemplateFunc func(f []template.FuncMap)

+ type HTTPConnector interface

+ Request func(method, path string, raw interface{}) (interface{}, error)

+ type HTTPSession interface

+ Request func() *http.Request

+ type HttpMeta struct

+ Method string

+ Path string

+ RequestCodec Codec

+ RequestType reflect.Type

+ ResponseCodec Codec

+ ResponseType reflect.Type

+ func HttpMetaByMethodURL(method, url string) *HttpMeta

+ func HttpMetaByRequestType(method string, t reflect.Type) *HttpMeta

+ func HttpMetaByResponseType(method string, t reflect.Type) *HttpMeta

+ func (self *HttpMeta) RequestTypeName() string

+ func (self *HttpMeta) ResponseTypeName() string

+ type MessageMeta struct

+ Codec Codec

+ ID int

+ Type reflect.Type

+ func MessageMetaByFullName(name string) *MessageMeta

+ func MessageMetaByID(id int) *MessageMeta

+ func MessageMetaByMsg(msg interface{}) *MessageMeta

+ func MessageMetaByType(t reflect.Type) *MessageMeta

+ func RegisterMessageMeta(meta *MessageMeta) *MessageMeta

+ func (self *MessageMeta) FullName() string

+ func (self *MessageMeta) GetContext(name string) (interface{}, bool)

+ func (self *MessageMeta) NewType() interface{}

+ func (self *MessageMeta) SetContext(name string, data interface{}) *MessageMeta

+ func (self *MessageMeta) TypeName() string

+ type MessageTransmitter interface

+ OnRecvMessage func(ses Session) (msg interface{}, err error)

+ OnSendMessage func(ses Session, msg interface{}) error

+ type Peer interface

+ Start func() Peer

+ Stop func()

+ TypeName func() string

+ type PeerProperty interface

+ Address func() string

+ Name func() string

+ Queue func() EventQueue

+ SetAddress func(v string)

+ SetName func(v string)

+ SetQueue func(v EventQueue)

+ type RawPacket struct

+ MsgData []byte

+ MsgID int

+ func (self *RawPacket) Message() interface{}

+ type RecvMsgEvent struct

+ Msg interface{}

+ Ses Session

+ func (self *RecvMsgEvent) Message() interface{}

+ func (self *RecvMsgEvent) Send(msg interface{})

+ func (self *RecvMsgEvent) Session() Session

+ type SendMsgEvent struct

+ Msg interface{}

+ Ses Session

+ func (self *SendMsgEvent) Message() interface{}

+ func (self *SendMsgEvent) Session() Session

+ type Session interface

+ Close func()

+ ID func() int64

+ Peer func() Peer

+ Raw func() interface{}

+ Send func(msg interface{})

+ type SessionAccepted struct

+ func (self *SessionAccepted) String() string

+ func (self *SessionAccepted) SystemMessage()

+ type SessionAccessor interface

+ CloseAllSession func()

+ GetSession func(int64) Session

+ SessionCount func() int

+ VisitSession func(func(Session) bool)

+ type SessionCloseNotify struct

+ func (self *SessionCloseNotify) String() string

+ func (self *SessionCloseNotify) SystemMessage()

+ type SessionClosed struct

+ Reason CloseReason

+ func (self *SessionClosed) String() string

+ func (self *SessionClosed) SystemMessage()

+ type SessionConnectError struct

+ func (self *SessionConnectError) String() string

+ func (self *SessionConnectError) SystemMessage()

+ type SessionConnected struct

+ func (self *SessionConnected) String() string

+ func (self *SessionConnected) SystemMessage()

+ type SessionInit struct

+ func (self *SessionInit) String() string

+ func (self *SessionInit) SystemMessage()

+ type TCPAcceptor interface

+ ListenPort func() int

+ type TCPConnector interface

+ ReconnectDuration func() time.Duration

+ Session func() Session

+ SetReconnectDuration func(time.Duration)

+ SetSessionManager func(raw interface{})

+ type TCPSocketOption interface

+ SetMaxPacketSize func(maxSize int)

+ SetSocketBuffer func(readBufferSize, writeBufferSize int, noDelay bool)

+ SetSocketDeadline func(read, write time.Duration)

+ type UDPAcceptor interface

+ SetSessionTTL func(dur time.Duration)

+ type UDPConnector interface

+ Session func() Session

+ type WSAcceptor interface

+ SetHttps func(certfile, keyfile string)