protocol_json

Documentation

Index

• Constants
• type IMessage
• type IMessageFactoryManager
• type IMessageHandlerManager
  • func NewMessageHandlerManager() IMessageHandlerManager
• type IProtocol
  • func New(allocator p.IAllocator, encryptor p.IEncryptor, decryptor p.IDecryptor) IProtocol
• type MessageHandler
• type MessageID

Constants

const (
	PH = 0
)

Types

type IMessage

type IMessage interface {
	Json()
	MessageID() MessageID
	Unmarshal([]byte) error
	Marshal() ([]byte, error)
	Reset()
	String() string
}

type IMessageFactoryManager

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

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

type IMessageHandlerManager

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

func NewMessageHandlerManager

func NewMessageHandlerManager() IMessageHandlerManager

type IProtocol

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

func New

func New(allocator p.IAllocator, encryptor p.IEncryptor, decryptor p.IDecryptor) IProtocol

type MessageHandler

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

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

type MessageID

type MessageID = string