Versions in this module Expand all Collapse all v1 v1.0.0 Jun 5, 2026 Changes in this version + const StatusDead + const StatusPending + const StatusProcessing + const StatusPublished + const TableName + var DefaultBackoff = backoff.Default + var ErrEmptyTopic = message.ErrEmptyTopic + var ErrInvalidSchema = config.ErrInvalidSchema + var ErrNilPayload = message.ErrNilPayload + var ErrNoCodec = errors.New("outbox: no codec configured (use WithCodec)") + var ErrNoExecutor = errors.New("outbox: a relay executor is required") + var ExpBackoff = backoff.Exp + var WithBatchSize = config.WithBatchSize + var WithCleanupInterval = config.WithCleanupInterval + var WithCodec = config.WithCodec + var WithConcurrency = config.WithConcurrency + var WithConfig = config.WithConfig + var WithHooks = config.WithHooks + var WithInstanceID = config.WithInstanceID + var WithLeaseDuration = config.WithLeaseDuration + var WithListenPool = config.WithListenPool + var WithLogger = config.WithLogger + var WithMaxAttempts = config.WithMaxAttempts + var WithOrdered = config.WithOrdered + var WithPollInterval = config.WithPollInterval + var WithRetention = config.WithRetention + var WithRetryBackoff = config.WithRetryBackoff + var WithSchema = config.WithSchema + var WithoutNotify = config.WithoutNotify + func Migrations() []string + func MigrationsFS() embed.FS + type Backoff = backoff.Backoff + type Codec = port.Codec + type Config = config.Config + type Executor = port.Executor + type Hooks = port.Hooks + type Message = message.Message + type NoopHooks = port.NoopHooks + type Option = config.Option + type Outbox struct + func New(exec Executor, enq Executor, pub Publisher, opts ...Option) (*Outbox, error) + func (o *Outbox) Enqueue(ctx context.Context, m Message) error + func (o *Outbox) EnqueueBatch(ctx context.Context, ms []Message) error + func (o *Outbox) EnqueueValue(ctx context.Context, topic, partitionKey, msgType string, v any) error + func (o *Outbox) Run(ctx context.Context) error + type Publisher = port.Publisher + type Settings = config.Settings + type Status = message.Status
Go to main page