Struct LockManager 

pub struct LockManager { /* private fields */ }

Lock manager for schedule locks

Implementations

impl LockManager

pub fn new(default_ttl: u64) -> Self

Create a new lock manager

Arguments

• default_ttl - Default time-to-live for locks in seconds

pub fn try_acquire( &mut self, task_name: &str, owner: &str, ttl: Option<u64>, ) -> Result<bool, ScheduleError>

Try to acquire a lock for a task

Arguments

• task_name - Name of the task to lock
• owner - Identifier of the lock owner
• ttl - Optional custom TTL (uses default if None)

Returns

• Ok(true) if lock acquired successfully
• Ok(false) if lock is already held by another owner
• Err on other errors

pub fn release( &mut self, task_name: &str, owner: &str, ) -> Result<bool, ScheduleError>

Release a lock

Arguments

• task_name - Name of the task to unlock
• owner - Identifier of the lock owner (must match)

Returns

• Ok(true) if lock was released
• Ok(false) if lock doesn’t exist or is owned by someone else

pub fn renew( &mut self, task_name: &str, owner: &str, ttl: Option<u64>, ) -> Result<bool, ScheduleError>

Renew an existing lock

Arguments

• task_name - Name of the task
• owner - Identifier of the lock owner (must match)
• ttl - Optional custom TTL (uses default if None)

Returns

• Ok(true) if lock was renewed
• Ok(false) if lock doesn’t exist, is owned by someone else, or has expired

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

Check if a lock is held

Arguments

• task_name - Name of the task

Returns

• true if lock exists and is not expired
• false otherwise

pub fn get_lock(&self, task_name: &str) -> Option<&ScheduleLock>

Get information about a lock

pub fn cleanup_expired(&mut self)

Clean up expired locks

pub fn get_active_locks(&self) -> Vec<&ScheduleLock>

Get all active locks

pub fn release_all(&mut self)

Force release all locks (use with caution)

Trait Implementations

impl Clone for LockManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LockManager

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

Formats the value using the given formatter.

impl Default for LockManager

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for LockManager

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LockManager

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.