postgres

Jan 18, 2026

Changes in this version

+ var ErrCircuitBreakerOpen = errors.New("circuit breaker open: database is unavailable")

+ var ErrDatabaseConnectionFailed = errors.New("failed to connect to database")

+ var ErrLockAcquisitionFailed = errors.New("failed to acquire lock after retries")

+ var ErrLockContention = errors.New("lock held by another process")

+ var ErrNoDatabase = errors.New("no database connection provided")

+ var ErrNotPostgreSQL = errors.New("database is not PostgreSQL; advisory locks are only supported on PostgreSQL")

+ func NewRWLocker(ctx context.Context, querier database.Querier, cfg Config, ...) (lock.RWLocker, error)

+ type Config struct

+ KeyPrefix string

+ type Locker struct

+ func NewLocker(ctx context.Context, querier database.Querier, cfg Config, ...) (*Locker, error)

+ func (l *Locker) Lock(ctx context.Context, key string, ttl time.Duration) error

+ func (l *Locker) TryLock(ctx context.Context, key string, ttl time.Duration) (bool, error)

+ func (l *Locker) Unlock(ctx context.Context, key string) error

+ type RWLocker struct

+ func (rw *RWLocker) RLock(ctx context.Context, key string, ttl time.Duration) error

+ func (rw *RWLocker) RUnlock(ctx context.Context, key string) error