Struct DistributedLock 

pub struct DistributedLock { /* private fields */ }

Lock factory. Cheap to clone.

Implementations

impl DistributedLock

pub fn new(cache: BoxedCache) -> Self

pub async fn try_acquire(&self, name: &str, ttl: Duration) -> Option<LockGuard>

Try to acquire name for ttl. Returns:

• Some(LockGuard) when we got it. Call release() when done (drop without release leaves the lock to expire on TTL — safe but slightly wasteful of contention slots).
• None when someone else holds it.

pub async fn with_lock<F, Fut, R>( &self, name: &str, ttl: Duration, body: F, ) -> Option<R>

where F: FnOnce() -> Fut, Fut: Future<Output = R>,

Acquire-or-skip helper: runs body only if we got the lock. Returns Some(R) when body ran, None when another holder blocked us. The lock is released after body finishes (or on panic, via the guard’s Drop — which is best-effort since we can’t call async fns from Drop).

Trait Implementations

impl Clone for DistributedLock

fn clone(&self) -> DistributedLock

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.