Versions in this module Expand all Collapse all v0 v0.0.0 Aug 5, 2022 Changes in this version + func NewGenericPeer(peerType, name, addr string, q cellnet.EventQueue) cellnet.GenericPeer + func NewPeer(peerType string) cellnet.Peer + func PeerCreatorList() (ret []string) + func RegisterPeerCreator(f PeerCreateFunc) + type CoreCaptureIOPanic struct + func (self *CoreCaptureIOPanic) CaptureIOPanic() bool + func (self *CoreCaptureIOPanic) EnableCaptureIOPanic(v bool) + type CoreContextSet struct + func (self *CoreContextSet) FetchContext(key, valuePtr interface{}) bool + func (self *CoreContextSet) GetContext(key interface{}) (interface{}, bool) + func (self *CoreContextSet) SetContext(key, v interface{}) + type CorePeerProperty struct + func (self *CorePeerProperty) Address() string + func (self *CorePeerProperty) Name() string + func (self *CorePeerProperty) Queue() cellnet.EventQueue + func (self *CorePeerProperty) SetAddress(v string) + func (self *CorePeerProperty) SetName(v string) + func (self *CorePeerProperty) SetQueue(v cellnet.EventQueue) + type CoreProcBundle struct + func (self *CoreProcBundle) GetBundle() *CoreProcBundle + func (self *CoreProcBundle) ProcEvent(ev cellnet.Event) + func (self *CoreProcBundle) ReadMessage(ses cellnet.Session) (msg interface{}, err error) + func (self *CoreProcBundle) SendMessage(ev cellnet.Event) + func (self *CoreProcBundle) SetCallback(v cellnet.EventCallback) + func (self *CoreProcBundle) SetHooker(v cellnet.EventHooker) + func (self *CoreProcBundle) SetTransmitter(v cellnet.MessageTransmitter) + type CoreRedisParameter struct + DBIndex int + Password string + PoolConnCount int + func (self *CoreRedisParameter) Init() + func (self *CoreRedisParameter) SetConnectionCount(v int) + func (self *CoreRedisParameter) SetDBIndex(v int) + func (self *CoreRedisParameter) SetPassword(v string) + type CoreRunningTag struct + func (self *CoreRunningTag) EndStopping() + func (self *CoreRunningTag) IsRunning() bool + func (self *CoreRunningTag) IsStopping() bool + func (self *CoreRunningTag) SetRunning(v bool) + func (self *CoreRunningTag) StartStopping() + func (self *CoreRunningTag) WaitStopFinished() + type CoreSQLParameter struct + PoolConnCount int + func (self *CoreSQLParameter) Init() + func (self *CoreSQLParameter) SetConnectionCount(v int) + func (self *CoreSQLParameter) SetPassword(v string) + type CoreSessionIdentify struct + func (self *CoreSessionIdentify) ID() int64 + func (self *CoreSessionIdentify) SetID(id int64) + type CoreSessionManager struct + func (self *CoreSessionManager) Add(ses cellnet.Session) + func (self *CoreSessionManager) CloseAllSession() + func (self *CoreSessionManager) Count() int + func (self *CoreSessionManager) GetSession(id int64) cellnet.Session + func (self *CoreSessionManager) Remove(ses cellnet.Session) + func (self *CoreSessionManager) SessionCount() int + func (self *CoreSessionManager) SetIDBase(base int64) + func (self *CoreSessionManager) VisitSession(callback func(cellnet.Session) bool) + type CoreTCPSocketOption struct + func (self *CoreTCPSocketOption) ApplySocketOption(conn net.Conn) + func (self *CoreTCPSocketOption) ApplySocketReadTimeout(conn net.Conn, callback func()) + func (self *CoreTCPSocketOption) ApplySocketWriteTimeout(conn net.Conn, callback func()) + func (self *CoreTCPSocketOption) Init() + func (self *CoreTCPSocketOption) MaxPacketSize() int + func (self *CoreTCPSocketOption) SetMaxPacketSize(maxSize int) + func (self *CoreTCPSocketOption) SetSocketBuffer(readBufferSize, writeBufferSize int, noDelay bool) + func (self *CoreTCPSocketOption) SetSocketDeadline(read, write time.Duration) + type MessagePoster interface + ProcEvent func(ev cellnet.Event) + type PeerCreateFunc func() cellnet.Peer + type SessionManager interface + Add func(cellnet.Session) + Count func() int + Remove func(cellnet.Session) + SetIDBase func(base int64)
Go to main page