ctxlock

package

v1.5.48 Latest Latest Go to latest Published: Dec 5, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Package ctxlock provides a locking mechanism based on context cancellation.

Contexts derived from a Locker are canceled when the underlying connection to the lock provider is gone, or when a parent context is canceled.

This section is empty.

This section is empty.

This section is empty.

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

Locker provides context-scoped locks.

func New(ctx context.Context, p *pgxpool.Pool) (*Locker, error)

New creates a Locker that will pull connections from the provided pool.

The provided context is only used for logging and initial setup. Close must be called to release held resources.

func (l *Locker) Close(_ context.Context) (_ error)

Close spins down background goroutines and frees resources.

func (l *Locker) Lock(parent context.Context, key string) (context.Context, context.CancelFunc)

Lock attempts to obtain the named lock until it succeeds or the passed Context is canceled.

func (l *Locker) TryLock(parent context.Context, key string) (context.Context, context.CancelFunc)

TryLock attempts to lock on the provided key.

If unsuccessful, an already-canceled Context will be returned.

If successful, the returned Context will be parented to the passed-in Context and also to the underlying connection used for the lock.