Versions in this module Expand all Collapse all v3 v3.0.0 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) Other modules containing this package github.com/temporalio/roadrunner-temporal/v2 github.com/temporalio/roadrunner-temporal/v4 github.com/temporalio/roadrunner-temporal/v5
Go to main page