Documentation
¶
Index ¶
- func NewAcceptor(q cellnet.EventQueue) cellnet.Peer
- func NewConnector(q cellnet.EventQueue) cellnet.Peer
- func NewConnectorBySessionManager(q cellnet.EventQueue, sm cellnet.SessionManager) cellnet.Peer
- func NewPacketList() *eventList
- func NewPrivatePacketReader() cellnet.EventHandler
- func NewPrivatePacketWriter() cellnet.EventHandler
- type Connector
- type PrivatePacketReader
- type PrivatePacketWriter
- type SocketOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAcceptor ¶
func NewAcceptor(q cellnet.EventQueue) cellnet.Peer
func NewConnector ¶
func NewConnector(q cellnet.EventQueue) cellnet.Peer
func NewConnectorBySessionManager ¶
func NewConnectorBySessionManager(q cellnet.EventQueue, sm cellnet.SessionManager) cellnet.Peer
func NewPacketList ¶
func NewPacketList() *eventList
func NewPrivatePacketReader ¶
func NewPrivatePacketReader() cellnet.EventHandler
TODO reader 问题 客户端处理链到PrivatePacketReader 之后停止
func NewPrivatePacketWriter ¶
func NewPrivatePacketWriter() cellnet.EventHandler
Types ¶
type Connector ¶
type Connector interface {
// 连接后的Session
DefaultSession() cellnet.Session
// 自动重连间隔, 0表示不重连, 默认不重连
SetAutoReconnectSec(sec int)
}
连接器, 可由Peer转换
type PrivatePacketReader ¶
type PrivatePacketReader struct {
// contains filtered or unexported fields
}
func (*PrivatePacketReader) Call ¶
func (self *PrivatePacketReader) Call(ev *cellnet.Event)
type PrivatePacketWriter ¶
type PrivatePacketWriter struct {
// contains filtered or unexported fields
}
func (*PrivatePacketWriter) Call ¶
func (self *PrivatePacketWriter) Call(ev *cellnet.Event)
type SocketOptions ¶
type SocketOptions interface {
// Session最大包大小, 超过这个数字, 接收视为错误, 断开连接
SetMaxPacketSize(size int)
MaxPacketSize() int
// 设置socket选项, 如果不修改,请设置-1
SetSocketOption(readBufferSize, writeBufferSize int, nodelay bool)
// 设置socket超时间隔, 0表示不作用
SetSocketDeadline(read, write time.Duration)
SocketDeadline() (read, write time.Duration)
}
Source Files
¶
- acceptor.go
- base.go
- connector.go
- evtlist.go
- handler_privatepkt.go
- log.go
- options.go
- session.go
Click to show internal directories.
Click to hide internal directories.