nnet

type CallbackWsPath func(http.ResponseWriter, *http.Request)

type Hub struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type HubConfig struct {
	SizeOfSendChan uint32
	SizeOfRecvChan uint32
	ReadBufSize    int
	WriteBufSize   int
	Timeout        time.Duration // 发送等超时
	Tick           time.Duration // 定时回调
	ReadTimeout    time.Duration // 讀超時，如果為0，則無限等待。超時到達，意味著客戶端心跳丟失
}

type IConn interface {
	io.ReadWriteCloser
	SetReadDeadline(time.Time) error
	SetWriteDeadline(time.Time) error
	RemoteAddr() net.Addr
	LocalAddr() net.Addr
}

type IHandler interface {
	Dispatch(ISession, IPacket) bool
}

type IHub interface {
	Lock() // support locker semantics
	Unlock()

	Wg() *sync.WaitGroup        // object
	ChQuit() <-chan struct{}    // 返回一个通道，用于退出 hub 循环
	Conf() *HubConfig           // 返回配置信息
	Callback() ISessionCallback // 返回回调对象
	Protocol() IProtocol        // 返回数据协议

	Start() error // 启动 hub
	Stop() error  // 停止 hub
	DoJob(int)    // 执行 hub 中其他任务

	PutSession(uint64, ISession) error // session 管理，这里的 session 必须基于　id
	DelSession(uint64) error
	GetSession(uint64) (ISession, error)
	PeekSession(uint64) (ISession, error)
	RandSession() (ISession, error)
	GetSessionNum() int
	GetAllSessions() map[uint64]ISession
}

type IMiddleware interface {
	BeforeSend([]byte) []byte
	AfterReceived([]byte) []byte
}

type IPacket interface {
	// serialize to binary format to be sent
	Serialize() []byte
	// free the memory if needs
	Destroy([]byte)
	// if need to close socket after sending this packet
	ShouldClose() (bool, int32)
}

type IProtocol interface {
	// parse by raw data to a packet
	ReadPacket(conn IConn) (IPacket, error)
}

type ISession interface {
	Do() // session 开始工作

	Close(int32) // 停止所有工作
	IsClosed() bool

	Write(IPacket, time.Duration) error
	AWrite(IPacket, time.Duration) error // 异步发送

	GetData() interface{} // 辅助数据
	SetData(interface{})

	UpdateId(uint64) //更新ID
	Id() uint64
	SetId(uint64)

	GetRawConn() IConn
}

type ISessionCallback interface {
	OnClosed(ISession, int32)
	OnConnected(ISession) (bool, int32)
	OnMessage(ISession, IPacket) bool
	OnHeartbeat(ISession) bool
}

type Packet struct {
	// contains filtered or unexported fields
}

type Protocol struct {
	BufSize int
}

type Session struct {
	// contains filtered or unexported fields
}

type TCPClient struct {
	*Hub
	// contains filtered or unexported fields
}

type TcpConn struct {
	*net.TCPConn
}

type TcpServer struct {
	*Hub
	// contains filtered or unexported fields
}

type WsClient struct {
	*Hub
	// contains filtered or unexported fields
}

type WsConn struct {
	*websocket.Conn
}

type WsServer struct {
	*Hub
	// contains filtered or unexported fields
}