Struct WorkspaceLockManager 

pub struct WorkspaceLockManager { /* private fields */ }

Manages per-project mutex locks to ensure concurrent runs for the same project are safely serialized without corrupting the persistent remote workspace.

Implementations

impl WorkspaceLockManager

pub fn new() -> Self

pub async fn get_lock(&self, project: &str) -> Arc<Mutex<()>>

Retrieve the shared mutex for the given project name.

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

Whether a run currently holds this project’s lock.

Non-inserting: projects with no lock entry are never locked. Used by GC and CLEAN paths to avoid deleting workspaces that are in use.

pub async fn locked_projects(&self) -> Vec<String>

Snapshot of project names whose locks are currently held. Callers building synchronous predicates (e.g. GC filters) use this to avoid holding the manager’s map across blocking work.

Trait Implementations

impl Clone for WorkspaceLockManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkspaceLockManager

fn default() -> Self

Returns the “default value” for a type.