Struct LockManager 

pub struct LockManager { /* private fields */ }

Thread-safe map from workflow Reference to per-workflow lock.

Used by higher-level workspace APIs to coordinate exclusive write access. The Default implementation is used for the global singleton.

Implementations

impl LockManager

pub fn get_mutex(reference: Arc<Reference>) -> Arc<Mutex<()>>

Acquires a workflow lock and returns a mutex for transactional use. The caller must call .lock() on the returned mutex to acquire the actual lock.

pub fn get_mutex_with_error_handling( reference: Arc<Reference>, ) -> Result<Arc<Mutex<()>>>

Enhanced lock acquisition with anyhow-compatible error handling Provides detailed error information for both poisoning and contention

pub fn try_get_mutex_with_timeout( reference: Arc<Reference>, timeout: Duration, ) -> Result<Arc<Mutex<()>>>

Try to acquire lock with timeout

pub fn is_locked(&self, reference: &Arc<Reference>) -> bool

Checks if a workflow is currently locked.

pub fn get_lock_metrics(&self) -> HashMap<String, u64>

Get lock metrics for monitoring and debugging

pub fn get_mutex_with_debug_error_handling( reference: Arc<Reference>, ) -> Result<Arc<Mutex<()>>>

Trait Implementations

impl Debug for LockManager

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

Formats the value using the given formatter.

impl Default for LockManager

fn default() -> LockManager

Returns the “default value” for a type.