ktcp

type CallBack interface {
	OnMessage(c Context)
	OnClose(c *Session)
}

type Context interface {
	context.Context
	GetSession() *Session
	ForwardHandler(c CallBack)
	GetReqMsg() *message.Message
	Bind(v interface{}) error
	Response() *message.Message
	Send(id uint32, resp interface{}) error
	SendError(id uint32, resp interface{}) error
	Middleware(middleware.Handler) middleware.Handler
	Reset(sess *Session, reqMsg *message.Message)
	AppendToStorage(saver storage.Saver)
	Save() (err error)
}

type Handler interface {
	CallBack
	OnConnect(s *Session)
}

type Server struct {
	Listener net.Listener
	Packer   packing.Packer // Packer is the message packer, will be passed to session.
	Codec    encoding.Codec // Codec is the message codec, will be passed to session.
	// contains filtered or unexported fields
}

type ServerOption func(*Server)

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