Documentation
¶
Overview ¶
Package sqlite provides a SQLite implementation of outbox.Store using database/sql. Use it with any SQLite database/sql driver (mattn/go-sqlite3, modernc.org/sqlite, etc.).
SQLite has no FOR UPDATE SKIP LOCKED. FetchPending wraps the claim in a short transaction; concurrent workers serialize on the database write lock, which is fine for most outbox workloads but does not scale to many parallel claimers the way PostgreSQL does.
Index ¶
- func CreateTableSQL(tableName string) string
- func Migrate(ctx context.Context, db osql.Execer, tableName string) error
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTableSQL ¶
CreateTableSQL returns the SQLite DDL for creating the outbox messages table.
SQLite has no native UUID, JSON or bytea types — TEXT/BLOB are used instead and IDs are generated by the Store on insert. The partial index requires SQLite 3.8 or newer.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store implements outbox.Store for SQLite.
func (*Store) FetchPending ¶
FetchPending atomically claims up to limit pending messages for processing. Wrapped in a transaction so the SELECT and UPDATE see a consistent snapshot.
func (*Store) MarkFailed ¶
MarkFailed increments retries and records the error. Sets status to failed when max retries reached, else back to pending.
func (*Store) MarkProcessed ¶
MarkProcessed marks messages as successfully processed.
Source Files