Versions in this module Expand all Collapse all v0 v0.1.0 Oct 4, 2026 Changes in this version + const Cols + func Placeholders(n int) string + func Scan(rows *sql.Rows) ([]xoutbox.Event, error) + type Base struct + D Dialect + DB *sql.DB + MaxAttempts int + Ordered bool + Table string + func New(db *sql.DB, d Dialect, opts []Option) *Base + func (b *Base) Cleanup(ctx context.Context, retention time.Duration) (int64, error) + func (b *Base) Filter() string + func (b *Base) Insert(ctx context.Context, ex xoutbox.Execer, events ...xoutbox.Event) error + func (b *Base) MarkFailed(ctx context.Context, owner string, f xoutbox.Failure) error + func (b *Base) MarkPublished(ctx context.Context, ids []string) error + func (b *Base) Migrate(ctx context.Context) error + func (b *Base) Q(s string) string + func (b *Base) Requeue(ctx context.Context, ids ...string) (int64, error) + func (b *Base) SchemaSQL() string + func (b *Base) Stats(ctx context.Context) (xoutbox.Stats, error) + type Dialect struct + Age string + Created string + Delete string + Dur string + DurArg func(time.Duration) any + Now string + Rebind func(string) string + Schema string + type Option func(*Base) + func WithMaxAttempts(n int) Option + func WithOrdering() Option + func WithTable(name string) Option
Go to main page