protocol_v2

type IMessage interface {
	V2()
	MessageID() MessageID
	Size() int
	Unmarshal([]byte) error
	Marshal() ([]byte, error)
	MarshalTo([]byte) (int, error)
	Reset()
	String() string
}

type IMessageFactoryManager interface {
	Register(iMsg IMessage, producer messageProducer, recycler messageRecycler)
	Produce(id MessageID) (IMessage, error)
	Recycle(iMsg IMessage) error
}

type IMessageHandlerManager interface {
	Register(id MessageID, handler MessageHandler)
	Process(iMsg IMessage, args ...interface{}) error
}

type IProtocol interface {
	IMessageFactoryManager
	Encode(i IMessage) ([]byte, error)
	Decode(data []byte) (IMessage, error)
}

type MessageHandler func(IMessage, ...interface{})

type MessageID = string