Struct LockRegistry 

pub struct LockRegistry {
    inner: Mutex<RegistryInner>,
}

Thread-safe in-memory registry of active resource locks.

Wrap in Arc<LockRegistry> and manage via Tauri’s state system.

Fields

inner: Mutex<RegistryInner>

Implementations

impl LockRegistry

pub fn new() -> Self

pub fn acquire( &self, scope: LockScope, op_name: impl Into<String>, ttl_secs: u64, now: i64, ) -> Result<LockId, AppError>

Acquire a lock for scope / op_name with ttl_secs TTL.

Returns the new LockId on success. Returns AppError::Locked when any existing lock has an intersecting scope.

The caller is responsible for emitting lock:acquired via lifecycle::emit_acquired.

pub fn heartbeat(&self, lock_id: &LockId, now: i64) -> Result<(), AppError>

Extend the heartbeat for lock_id.

Returns AppError::NotFound if the lock does not exist.

pub fn release(&self, lock_id: &LockId) -> Result<ResourceLock, AppError>

Release a lock explicitly.

Returns AppError::NotFound if the lock does not exist. The returned ResourceLock carries the scope needed for the event.

pub fn list(&self, scope_filter: Option<&LockScope>) -> Vec<ResourceLock>

Return all active locks, optionally filtered to those whose scope intersects scope_filter.

pub fn release_stale(&self, now: i64) -> Vec<ResourceLock>

Release all locks whose TTL has expired relative to now.

Returns the released locks so the caller can emit events.

pub fn startup_cleanup(&self) -> Vec<ResourceLock>

Remove all locks regardless of TTL.

Called once at app start to clear any locks left over from a prior crash or abnormal exit. Returns the removed locks so the caller can emit lock:released { reason: StartupCleanup } for each.

Trait Implementations

impl Default for LockRegistry

fn default() -> Self

Returns the “default value” for a type.