Struct DistributedLock 

pub struct DistributedLock { /* private fields */ }

Distributed lock manager

Implementations

impl DistributedLock

pub fn new() -> Self

Create new lock manager

pub fn with_ttl(self, ttl: Duration) -> Self

Configure default TTL

pub async fn acquire( &self, resource: &str, timeout: Duration, ) -> Result<LockToken>

Acquire lock on resource

pub fn try_acquire(&self, resource: &str) -> Option<LockToken>

Try to acquire lock (non-blocking)

pub async fn release(&self, token: &str) -> Result<()>

Release lock

pub fn is_locked(&self, resource: &str) -> bool

Check if resource is locked

pub fn extend(&self, token: &str, additional: Duration) -> Result<()>

Extend lock TTL

pub fn cleanup_expired(&self)

Cleanup expired locks

pub fn count(&self) -> usize

Get lock count

Trait Implementations

impl Default for DistributedLock

fn default() -> Self

Returns the “default value” for a type.