The highest tagged major version is v5.

queue

package

v1.2.0-rc.4 Latest Latest Go to latest Published: Feb 3, 2022 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MessageQueue struct {
	SeqID func() uint64
	Queue []*internal.Message
}

func NewMessageQueue(sedID func() uint64) *MessageQueue

func (mq *MessageQueue) AllocateMessage(cmd interface{}, payloads *common.Payloads, header *common.Header) (uint64, internal.Message)

func (mq *MessageQueue) Flush()

func (mq *MessageQueue) PushCommand(cmd interface{}, payloads *common.Payloads, header *common.Header) uint64

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

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