Function AcquireAdvisoryXactLockWithStringKey

backend/store/advisory_lock.go:90–93

AcquireAdvisoryXactLockWithStringKey acquires a transaction-level advisory lock scoped by namespace and string key, blocking until the lock is available. The lock is automatically released when the transaction ends.

(ctx context.Context, tx *sql.Tx, namespace AdvisoryLockKey, key string)

// lock scoped by namespace and string key, blocking until the lock is available.
// The lock is automatically released when the transaction ends.
func AcquireAdvisoryXactLockWithStringKey(ctx context.Context, tx *sql.Tx, namespace AdvisoryLockKey, key string) error {
	_, err := tx.ExecContext(ctx, "SELECT pg_advisory_xact_lock($1, hashtext($2))", int32(namespace), key)
	return err
}

// Release releases the advisory lock and returns the connection to the pool.
// Uses context.Background() to ensure cleanup completes even if parent ctx is cancelled.