Versions in this module Expand all Collapse all v0 v0.0.2 May 3, 2026 v0.0.1 May 3, 2026 Changes in this version + type Store struct + func New[T comparable](db *sql.DB) *Store[T] + func (s *Store[T]) FetchPending(ctx context.Context, limit int) ([]xoutbox.Event[T], error) + func (s *Store[T]) InsertEvent(ctx context.Context, event xoutbox.Event[T]) error + func (s *Store[T]) MarkFailed(ctx context.Context, id T, retryCount int) error + func (s *Store[T]) MarkPublished(ctx context.Context, id T) error
Go to main page