store

package

v0.3.1 Latest Latest Go to latest Published: Aug 1, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/yudhasubki/blockqueue

Links

Open Source Insights

Documentation ¶

Overview ¶

Package store defines the small database boundary used by BlockQueue.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Dialect ¶

type Dialect string

Dialect selects backend-specific SQL and locking behavior.

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

Durability selects the backend commit-strength profile.

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

type NotificationHealthSource ¶ added in v0.3.0

type NotificationHealthSource interface {
	NotificationHealthy() bool
}

NotificationHealthSource optionally exposes the state of the driver's dedicated listener connection. It is operational health only; polling keeps queue correctness independent from this signal.

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.

Source Files ¶

View all Source files

driver.go

Directories ¶

Path	Synopsis
postgres Package postgres provides the production PostgreSQL storage driver.	Package postgres provides the production PostgreSQL storage driver.
sqlite Package sqlite provides the production SQLite storage driver.	Package sqlite provides the production SQLite storage driver.
turso Package turso provides experimental libSQL/Turso storage support.	Package turso provides experimental libSQL/Turso storage support.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL