gnet

type Callback struct {
	OnSession     func(NetSession)
	OnMessage     func(Event)
	OnSessionStop func(NetSession)
}

type Event interface {
	// Session返回本条消息对应的NetSession
	Session() NetSession

	// Message返回经过unPack,decode之后的消息
	Message() interface{}
}

type Module interface {
	Pool() pool.Pool
	Coder() codec.Coder
	Packer() packer.Packer
}

type NetClient interface {
	SessionManager
	Runner
}

type NetServer interface {
	SessionManager
	Runner
}

type NetSession interface {
	ID() uint64
	LocalAddr() net.Addr
	RemoteAddr() net.Addr

	Send(message interface{})
	AccessManager() SessionManager

	Runner
}

type Operator interface {
	PostEvent(ev Event)
	Read(reader io.Reader) (interface{}, error)
	Write(writer io.Writer, msg interface{}) error

	GetCallback() Callback
}

type ReadInterceptor struct {
	PreRead  func(r io.Reader, m meta.Meta) (io.Reader, meta.Meta)
	InRead   func(buf []byte, m meta.Meta) ([]byte, meta.Meta)
	PostRead func(msg interface{}) interface{}
}

type Runner interface {
	Run()
	Stop()
}

type SessionManager interface {
	// BroadCast对所有NetSession连接执行fn
	// 若module设置Pool,则fn全部投入Pool中,否则在当前goroutine执行
	Broadcast(func(session NetSession))

	// GetSession返回指定id对应的NetSession
	GetSession(id uint64) (NetSession, bool)
}

type WriteInterceptor struct {
	PreWrite func(w io.Writer, msg interface{}) (io.Writer, interface{})
	InWrite  func(w io.Writer, buf []byte) (io.Writer, []byte)
}