outbox

Oct 8, 2025

Changes in this version

+ var ErrRecordNotFound = errors.New("record not found")

+ func WithLogger[T any](logger *slog.Logger) option[T]

+ func WithMaxRetries[T any](n int) option[T]

+ func WithNumberOfRoutines[T any](n int) option[T]

+ type DeadLetterQueue interface

+ Send func(context.Context, any, error) error

+ type EncodeDecoder interface

+ Decode func(raw []byte) (T, error)

+ Encode func(data T) ([]byte, error)

+ type MessageBroker interface

+ Send func(context.Context, T) error

+ type Outbox interface

+ SendTx func(ctx context.Context, tx *sql.Tx, msg T) error

+ func New[T any](s Store, mb MessageBroker[T], dlq DeadLetterQueue, opts ...option[T]) Outbox[T]

+ type Record struct

+ CreatedAt time.Time

+ ID xid.ID

+ LastAttemptAt *time.Time

+ Message []byte

+ NumberOfAttempts int

+ type Store interface

+ CreateRecordTx func(context.Context, *sql.Tx, Record) (*Record, error)

+ Delete func(context.Context, xid.ID) error

+ GetWithLock func(context.Context, xid.ID) (*Record, error)

+ Listen func() <-chan xid.ID

+ ProcessTx func(context.Context, func(Store) bool) error

+ Update func(context.Context, *Record) error