db

package

v0.7.0-rc.2 Latest Latest Go to latest Published: Sep 14, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func RunMigrations(databaseURL string) error

RunMigrations runs all pending database migrations using goose.

type AdvisoryLock struct {
	// contains filtered or unexported fields
}

AdvisoryLock holds one session-level PostgreSQL advisory lock on a dedicated pool connection. Unlock must be called exactly once.

func (l *AdvisoryLock) Unlock()

Unlock releases the advisory lock and its dedicated connection.

type DB struct {
	// contains filtered or unexported fields
}

DB wraps a pgxpool.Pool.

func New(ctx context.Context, databaseURL string) *DB

New creates a new DB, connecting to the given database URL.

func (d *DB) AcquireAdvisoryLock(ctx context.Context, key string) (*AdvisoryLock, error)

AcquireAdvisoryLock serializes cross-replica work identified by key without holding row locks needed by callbacks performed during that work.

func (d *DB) Close()

Close closes the connection pool.

func (d *DB) Pool() *pgxpool.Pool

Pool returns the underlying pool.

func (d *DB) TryAcquireAdvisoryLock(ctx context.Context, key string) (*AdvisoryLock, bool, error)

TryAcquireAdvisoryLock obtains the lock without waiting.

Path	Synopsis
dbq