socket

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
  • func (self *PrivatePacketReader) Call(ev *cellnet.Event)
• type PrivatePacketWriter
  • func (self *PrivatePacketWriter) Call(ev *cellnet.Event)
• type SocketOptions

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)
}