Struct AdvisoryLocks 

pub struct AdvisoryLocks { /* private fields */ }

Process-global table. One per runtime is enough; lock ids are a shared namespace across connections by PG semantics.

Implementations

impl AdvisoryLocks

pub fn try_acquire(&self, key: i64, conn: u64) -> bool

Try to acquire key for conn. Returns true if the caller now owns it (either fresh acquire or already holds it — reentrant within the same connection, matching PG). Never blocks.

pub fn acquire(&self, key: i64, conn: u64)

Acquire key for conn, blocking until the current owner (if any) releases. Reentrant within the same connection.

pub fn release(&self, key: i64, conn: u64) -> bool

Release key for conn. Returns true if conn held the lock. A mismatch returns false and leaves the table untouched (PG behaviour: pg_advisory_unlock returns bool without panicking on foreign locks).

pub fn release_all(&self, conn: u64) -> usize

Release every lock held by conn. Returns the number of locks dropped. Call this on connection close.