Versions in this module Expand all Collapse all v0 v0.2.0 May 19, 2026 Changes in this version + type Repository struct + func New(db *gormdb.DBClient, table string) *Repository + func (r *Repository) Claim(ctx context.Context, batch int) ([]outbox.Message, error) + func (r *Repository) Enqueue(ctx context.Context, drafts ...outbox.MessageDraft) error + func (r *Repository) MarkDone(ctx context.Context, id string) error + func (r *Repository) MarkFailed(ctx context.Context, id string, handlerErr error, retryAt time.Time) error
Go to main page