Documentation
¶
Overview ¶
Package outbox_queue implements the queue.Queue contract on top of the outbox: each task is stored as an outbox message whose subject carries the channel, so the relay ships it to the work-queue stream.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutboxQueue ¶
type OutboxQueue struct {
// contains filtered or unexported fields
}
OutboxQueue implements queue.Queue by reusing the outbox publisher.
func NewOutboxQueue ¶
func NewOutboxQueue(publisher outbox.Outbox) *OutboxQueue
Source Files
Click to show internal directories.
Click to hide internal directories.