store

type Dialect ¶

type Dialect string

const (
	DialectSQLite   Dialect = "sqlite"
	DialectPostgres Dialect = "postgres"
)

type Driver ¶

type Driver interface {
	DB() *sql.DB
	Dialect() Dialect
	DriverName() string
	Close() error
}

Driver intentionally exposes only database/sql. SQL builders, rebinding, migrations, and sqlx are implementation details of the queue engine.

type Durability ¶

type Durability string

const (
	DurabilityStrict   Durability = "strict"
	DurabilityBalanced Durability = "balanced"
)

type NotificationSource ¶

type NotificationSource interface {
	Listen(context.Context, string) (<-chan string, error)
}

NotificationSource is an optional capability. Queue correctness never depends on notifications; supported drivers use them to avoid polling latency while bounded reconciliation remains the fallback.

type SQLiteMaintenanceSource ¶

type SQLiteMaintenanceSource interface {
	SQLiteMaintenanceEnabled() bool
}

SQLiteMaintenanceSource marks a local SQLite driver that supports WAL checkpoint and incremental-vacuum pragmas. Remote SQLite-compatible drivers such as Turso intentionally do not implement this capability.