Struct ResourceLockManager 

pub struct ResourceLockManager { /* private fields */ }

Manages resource locks (build/test/git) across multiple agents

Uses liveness-based validation instead of fixed timeouts:

• Integrates with OperationTracker for heartbeat monitoring
• Locks are valid as long as the holder is alive
• Supports wait queue for coordinated access

Implementations

impl ResourceLockManager

pub fn new() -> Self

Create a new resource lock manager

pub fn with_operation_tracker(operation_tracker: Arc<OperationTracker>) -> Self

Create a resource lock manager with operation tracker integration

pub fn with_full_integration( operation_tracker: Arc<OperationTracker>, wait_queue: Arc<WaitQueue>, ) -> Self

Create a fully integrated resource lock manager

pub fn subscribe(&self) -> Receiver<LockNotification>

Subscribe to lock notifications

pub fn operation_tracker(&self) -> Option<&Arc<OperationTracker>>

Get the operation tracker if configured

pub fn wait_queue(&self) -> Option<&Arc<WaitQueue>>

Get the wait queue if configured

pub async fn acquire_resource( self: &Arc<Self>, agent_id: &str, resource_type: ResourceType, scope: ResourceScope, description: &str, ) -> Result<ResourceLockGuard>

Acquire a resource lock

Returns a ResourceLockGuard that automatically releases the lock when dropped.

pub async fn acquire_with_operation( self: &Arc<Self>, agent_id: &str, resource_type: ResourceType, scope: ResourceScope, description: &str, ) -> Result<(ResourceLockGuard, Option<OperationHandle>)>

Acquire a resource lock with operation tracking

This method creates an OperationHandle that:

• Automatically sends heartbeats
• Can have a process attached for liveness monitoring
• Signals completion when dropped

pub async fn release_resource( &self, agent_id: &str, resource_type: ResourceType, scope: &ResourceScope, ) -> Result<()>

Release a specific resource lock

pub async fn release_all_for_agent(&self, agent_id: &str) -> usize

Release all locks held by an agent

pub async fn can_acquire( &self, agent_id: &str, resource_type: ResourceType, scope: &ResourceScope, ) -> bool

Check if a resource can be acquired by an agent

pub async fn get_blocking_locks( &self, agent_id: &str, resource_type: ResourceType, scope: &ResourceScope, ) -> Vec<ResourceLockInfo>

Get detailed information about what’s blocking acquisition

pub async fn query_lock_status( &self, resource_type: ResourceType, scope: &ResourceScope, ) -> Option<LockStatus>

Query the detailed status of a lock

pub async fn check_lock( &self, resource_type: ResourceType, scope: &ResourceScope, ) -> Option<ResourceLockInfo>

Check if a resource is currently locked

pub async fn force_release( &self, resource_type: ResourceType, scope: &ResourceScope, ) -> Result<()>

Force release a lock (admin operation)

pub async fn list_locks(&self) -> Vec<ResourceLockInfo>

Get all currently held locks

pub async fn locks_for_agent(&self, agent_id: &str) -> Vec<ResourceLockInfo>

Get locks held by a specific agent

pub async fn cleanup_stale(&self) -> usize

Clean up stale locks (public version)

pub async fn stats(&self) -> ResourceLockStats

Get statistics about current locks

pub async fn update_lock_status( &self, agent_id: &str, resource_type: ResourceType, scope: &ResourceScope, status: &str, ) -> Result<()>

Update the status of a held lock

Trait Implementations

impl Default for ResourceLockManager

fn default() -> Self

Returns the “default value” for a type.