Struct OperationTracker 

pub struct OperationTracker { /* private fields */ }

Tracks active operations with heartbeat-based liveness checking

Implementations

impl OperationTracker

pub fn new() -> Arc<Self>

Create a new operation tracker with default settings

pub fn with_config( heartbeat_interval: Duration, max_missed_heartbeats: u32, ) -> Arc<Self>

Create a new operation tracker with custom settings

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

Subscribe to operation events

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

Start tracking a new operation

Returns an OperationHandle that:

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

pub async fn heartbeat(&self, operation_id: &str, status: &str) -> Result<()>

Update heartbeat and status for an operation

pub async fn add_output(&self, operation_id: &str, line: &str) -> Result<()>

Add output line to an operation

pub async fn attach_process( &self, operation_id: &str, process_id: u32, ) -> Result<()>

Attach a process ID to an operation for liveness monitoring

pub async fn is_alive(&self, operation_id: &str) -> bool

Check if an operation is still alive

pub async fn get_status(&self, operation_id: &str) -> Option<OperationStatus>

Get status of an operation

pub async fn list_operations(&self) -> Vec<OperationStatus>

Get all active operations

pub async fn operations_for_agent(&self, agent_id: &str) -> Vec<OperationStatus>

Get operations for a specific agent

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

Find operations by resource type and scope

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

Clean up stale operations (those with expired heartbeats)

Trait Implementations

impl Default for OperationTracker

fn default() -> Self

Returns the “default value” for a type.