mysql

package

v0.1.0 Latest Latest Go to latest Published: Oct 4, 2026 License: MIT Imports: 6 Imported by: 0

Details

Package mysql is an xoutbox.Store for MySQL 8.0+ / MariaDB 10.6+ using database/sql.

This section is empty.

This section is empty.

This section is empty.

type Option = sqlstore.Option

Option configures the store.

func WithMaxAttempts(n int) Option

WithMaxAttempts sets the default attempt limit for new events (default 10).

func WithOrdering() Option

WithOrdering enables strict per-key ordering (head-of-line blocking per Key).

func WithTable(name string) Option

WithTable sets the table name (default "outbox").

type Store struct{ *sqlstore.Base }

Store implements xoutbox.Store and xoutbox.Cleaner.

func New(db *sql.DB, opts ...Option) *Store

func (s *Store) Claim(ctx context.Context, owner string, limit int, lease time.Duration) ([]xoutbox.Event, error)

Claim leases due rows inside a short transaction using FOR UPDATE SKIP LOCKED.