queue

Jan 10, 2023

Changes in this version

+ type MessageQueue struct

+ SeqID func() uint64

+ func NewMessageQueue(sedID func() uint64) *MessageQueue

+ func (mq *MessageQueue) AllocateMessage(cmd any, payloads *common.Payloads, header *common.Header) *internal.Message

+ func (mq *MessageQueue) Flush()

+ func (mq *MessageQueue) Messages() []*internal.Message

+ func (mq *MessageQueue) PushCommand(cmd any, payloads *common.Payloads, header *common.Header)

+ func (mq *MessageQueue) PushError(id uint64, failure *failure.Failure)

+ func (mq *MessageQueue) PushResponse(id uint64, payloads *common.Payloads)