Struct PostgresDistributedLock 

pub struct PostgresDistributedLock { /* private fields */ }

PostgreSQL-based distributed lock implementation

Uses PostgreSQL advisory locks for distributed coordination. Advisory locks are fast, automatically cleaned up on connection termination, and support both blocking and non-blocking acquisition.

Implementations

impl PostgresDistributedLock

pub async fn new(database_url: &str) -> StateResult<Self>

Create a new PostgreSQL distributed lock

Arguments

• database_url - PostgreSQL connection URL

Returns

• Ok(PostgresDistributedLock) - Lock instance created
• Err(StateError) - Failed to connect to database

pub async fn with_pool_size( database_url: &str, max_connections: u32, ) -> StateResult<Self>

Create a new PostgreSQL distributed lock with custom pool size

Arguments

• database_url - PostgreSQL connection URL
• max_connections - Maximum number of connections in the pool

Trait Implementations

impl Debug for PostgresDistributedLock

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DistributedLock for PostgresDistributedLock

fn acquire<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ttl: Duration, ) -> Pin<Box<dyn Future<Output = StateResult<LockGuard>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Acquire a lock for the given resource

fn try_acquire<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ttl: Duration, ) -> Pin<Box<dyn Future<Output = StateResult<Option<LockGuard>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Try to acquire a lock without blocking

fn release_internal<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, resource: &'life1 str, token: &'life2 LockToken, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Internal release method (used by Drop)

fn is_locked<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if a resource is currently locked

fn extend<'life0, 'life1, 'async_trait>( &'life0 self, guard: &'life1 mut LockGuard, ttl: Duration, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Extend the TTL of an existing lock

fn get_lock_info<'life0, 'life1, 'async_trait>( &'life0 self, resource: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<Option<LockToken>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get information about who holds a lock

fn release<'life0, 'async_trait>( &'life0 self, guard: LockGuard, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Release a lock

impl Drop for PostgresDistributedLock

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.