Versions in this module Expand all Collapse all v6 v6.0.0 Oct 8, 2026 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, ...) + func (mq *MessageQueue) Flush() + func (mq *MessageQueue) Messages() []*internal.Message + func (mq *MessageQueue) PushCommand(cmd any, payloads *common.Payloads, header *common.Header, wfPid int) + func (mq *MessageQueue) PushError(id uint64, failure *failure.Failure, wfPid int) + func (mq *MessageQueue) PushResponse(id uint64, payloads *common.Payloads, wfPid int) v6.0.0-beta.1 Aug 22, 2026 Other modules containing this package github.com/temporalio/roadrunner-temporal/v2 github.com/temporalio/roadrunner-temporal/v3 github.com/temporalio/roadrunner-temporal/v4 github.com/temporalio/roadrunner-temporal/v5
Go to main page