rpc

type IMessage interface {
	proto.Message
	Size() int
	Marshal() (dAtA []byte, err error)
	Unmarshal([]byte) error
	RPC()
	MessageID() MessageID
	MessageName() string
	ResetEx()
	ResponseMessageID() MessageID
}

type IMessageDispatcher interface {
	Register(id MessageID, handler MessageHandler) (err error)
	Dispatch(iProtocol IProtocol, sender *actor.PID, iRecv IMessage, ctx actor.Context, args ...interface{}) (iSend IMessage, err error)
}

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

type IProtocol interface {
	IMessageFactoryManager
}

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

type MessageHandler func(sender *actor.PID, iRecv IMessage, iSend IMessage, ctx actor.Context, args ...interface{})

type MessageID = uint32

type MessageProducer func() IMessage

type MessageRecycler func(IMessage)