Versions in this module Expand all Collapse all v0 v0.0.1 Nov 10, 2025 Changes in this version + type MySQL struct + func NewMySQL(db *sql.DB, opts ...MySQLOption) *MySQL + func (s *MySQL) Add(ctx context.Context, exec txoutbox.Executor, msg txoutbox.Message) error + func (s *MySQL) Claim(ctx context.Context, workerID string, limit int, leaseTTL time.Duration) ([]txoutbox.Envelope, error) + func (s *MySQL) Fail(ctx context.Context, id int64, retryCount int) error + func (s *MySQL) Retry(ctx context.Context, id int64, retryCount int, nextRetry time.Time) error + func (s *MySQL) Send(ctx context.Context, id int64, sendAt time.Time) error + type MySQLOption func(*MySQL) + func WithMySQLNow(now func() time.Time) MySQLOption + func WithMySQLTable(table string) MySQLOption + type Postgres struct + func NewPostgres(db *sql.DB, opts ...PostgresOption) *Postgres + func (s *Postgres) Add(ctx context.Context, exec txoutbox.Executor, msg txoutbox.Message) error + func (s *Postgres) Claim(ctx context.Context, workerID string, limit int, leaseTTL time.Duration) ([]txoutbox.Envelope, error) + func (s *Postgres) Fail(ctx context.Context, id int64, retryCount int) error + func (s *Postgres) Retry(ctx context.Context, id int64, retryCount int, nextRetry time.Time) error + func (s *Postgres) Send(ctx context.Context, id int64, sendAt time.Time) error + type PostgresOption func(*Postgres) + func WithPostgresNow(now func() time.Time) PostgresOption + func WithPostgresTable(table string) PostgresOption + type SQLite struct + func NewSQLite(db *sql.DB, opts ...SQLiteOption) *SQLite + func (s *SQLite) Add(ctx context.Context, exec txoutbox.Executor, msg txoutbox.Message) error + func (s *SQLite) Claim(ctx context.Context, workerID string, limit int, leaseTTL time.Duration) ([]txoutbox.Envelope, error) + func (s *SQLite) Fail(ctx context.Context, id int64, retryCount int) error + func (s *SQLite) Retry(ctx context.Context, id int64, retryCount int, nextRetry time.Time) error + func (s *SQLite) Send(ctx context.Context, id int64, sendAt time.Time) error + type SQLiteOption func(*SQLite) + func WithSQLiteNow(now func() time.Time) SQLiteOption + func WithSQLiteTable(name string) SQLiteOption
Go to main page