Struct DistributedLockManager 

pub struct DistributedLockManager { /* private fields */ }

Thread-safe distributed lock manager (in-memory; production implementations use Redis or etcd).

Implementations

impl DistributedLockManager

pub fn new() -> Self

pub fn try_acquire( &self, resource: &str, holder: &str, ttl: Duration, ) -> Option<u64>

Try to acquire a lock. Returns the fencing token if acquired, or None if the resource is held by another holder.

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

Release a lock. Only the holder can release.

pub fn renew( &self, resource: &str, holder: &str, ttl: Duration, ) -> Option<DateTime<Utc>>

Renew an existing lease. Returns the new expiry time.

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

Check if a resource is currently locked.

pub fn holder(&self, resource: &str) -> Option<String>

Get the current holder of a resource.

pub fn purge_expired(&self) -> usize

Purge expired leases.

pub fn active_count(&self) -> usize

Number of active leases.

Trait Implementations

impl Default for DistributedLockManager

fn default() -> Self

Returns the “default value” for a type.