sqlite

May 18, 2026

Changes in this version

+ const DefaultProcessedTable

+ func CreateProcessedTableSQL(tableName string) string

+ func MigrateProcessed(ctx context.Context, db osql.Execer, tableName string) error

+ type ProcessedStore struct

+ func NewProcessed(tableName string) *ProcessedStore

+ func (s *ProcessedStore) IsProcessed(ctx context.Context, db any, group, msgID string) (bool, error)

+ func (s *ProcessedStore) MarkProcessed(ctx context.Context, db any, group, msgID string, metadata json.RawMessage) (bool, error)

+ func (s *ProcessedStore) PurgeProcessedBefore(ctx context.Context, db any, t time.Time) (int64, error)

type Store

+ func (s *Store) DeleteProcessedBefore(ctx context.Context, t time.Time) (int64, error)

Apr 8, 2026

Changes in this version

+ func CreateTableSQL(tableName string) string

+ func Migrate(ctx context.Context, db osql.Execer, tableName string) error

+ type Store struct

+ func New(db *stdsql.DB, options ...osql.Option) *Store

+ func (s *Store) FetchPending(ctx context.Context, limit int) ([]outbox.Message, error)

+ func (s *Store) MarkFailed(ctx context.Context, id string, err error) error

+ func (s *Store) MarkProcessed(ctx context.Context, ids ...string) error

+ func (s *Store) Save(ctx context.Context, tx any, msgs ...outbox.Message) error