Struct ProcessRegistry 

pub struct ProcessRegistry { /* private fields */ }

Implementations

impl ProcessRegistry

pub fn new() -> Self

pub fn generate_id(&self) -> Result<i64, String>

pub async fn register_process( &self, config: ProcessRegistrationConfig, child: Child, ) -> Result<(), String>

pub async fn register_sidecar_process( &self, config: ProcessRegistrationConfig, ) -> Result<(), String>

pub async fn register_claude_session( &self, session_id: String, pid: u32, project_path: String, task: String, model: String, child: Arc<Mutex<Option<Child>>>, ) -> Result<i64, String>

pub async fn get_running_claude_sessions( &self, ) -> Result<Vec<ProcessInfo>, String>

pub async fn get_claude_session_by_id( &self, session_id: &str, ) -> Result<Option<ProcessInfo>, String>

pub async fn unregister_process(&self, run_id: i64) -> Result<(), String>

pub async fn get_running_processes(&self) -> Result<Vec<ProcessInfo>, String>

pub async fn get_running_agent_processes( &self, ) -> Result<Vec<ProcessInfo>, String>

pub async fn get_process( &self, run_id: i64, ) -> Result<Option<ProcessInfo>, String>

pub async fn kill_process(&self, run_id: i64) -> Result<bool, String>

pub async fn kill_process_by_pid( &self, run_id: i64, pid: u32, ) -> Result<bool, String>

pub async fn is_process_running(&self, run_id: i64) -> Result<bool, String>

pub async fn append_live_output( &self, run_id: i64, output: &str, ) -> Result<(), String>

pub async fn get_live_output(&self, run_id: i64) -> Result<String, String>

pub async fn cleanup_finished_processes(&self) -> Result<Vec<i64>, String>

Trait Implementations

impl Default for ProcessRegistry

fn default() -> Self

Returns the “default value” for a type.