Struct BgTaskRegistry 

pub struct BgTaskRegistry { /* private fields */ }

Implementations

impl BgTaskRegistry

pub fn new(progress_sender: SharedProgressSender) -> Self

pub fn set_harness(&self, harness: Harness)

pub fn set_db_pool(&self, conn: Arc<Mutex<Connection>>)

pub fn clear_db_pool(&self)

pub fn set_compressor<F>(&self, compressor: F)

where F: Fn(&str, String) -> CompressionResult + Send + Sync + 'static,

Install the output-compression callback. Called by main.rs after AppContext is constructed so that snapshot/completion paths can invoke compress::compress_with_registry without holding a context reference. When called multiple times, the latest installation wins.

pub fn set_compressor_with_exit_code<F>(&self, compressor: F)

where F: Fn(&str, String, Option<i32>) -> CompressionResult + Send + Sync + 'static,

pub fn configure_long_running_reminders(&self, enabled: bool, interval_ms: u64)

pub fn spawn( &self, command: &str, session_id: String, workdir: PathBuf, env: HashMap<String, String>, timeout: Option<Duration>, storage_dir: PathBuf, max_running: usize, notify_on_completion: bool, compressed: bool, project_root: Option<PathBuf>, ) -> Result<String, String>

pub fn spawn_pty( &self, command: &str, session_id: String, workdir: PathBuf, env: HashMap<String, String>, timeout: Option<Duration>, storage_dir: PathBuf, max_running: usize, notify_on_completion: bool, compressed: bool, project_root: Option<PathBuf>, rows: u16, cols: u16, ) -> Result<String, String>

pub fn write_pty( &self, task_id: &str, session_id: &str, input: &[u8], ) -> Result<usize, String>

pub fn replay_session( &self, storage_dir: &Path, session_id: &str, ) -> Result<(), String>

pub fn replay_session_for_project( &self, storage_dir: &Path, session_id: &str, project_root: &Path, ) -> Result<(), String>

pub fn register_watch( &self, task_id: String, pattern: WatchPattern, once: bool, ) -> Result<String, &'static str>

pub fn unregister_watch(&self, task_id: &str, watch_id: &str)

pub fn active_watch_count(&self, task_id: &str) -> usize

pub fn status( &self, task_id: &str, session_id: &str, project_root: Option<&Path>, storage_dir: Option<&Path>, preview_bytes: usize, ) -> Option<BgTaskSnapshot>

pub fn kill_relaxed( &self, task_id: &str, project_root: &Path, storage_dir: &Path, ) -> Result<BgTaskSnapshot, String>

pub fn maybe_gc_persisted(&self, storage_dir: &Path) -> Result<usize, String>

pub fn list(&self, preview_bytes: usize) -> Vec<BgTaskSnapshot>

pub fn kill( &self, task_id: &str, session_id: &str, ) -> Result<BgTaskSnapshot, String>

pub fn promote(&self, task_id: &str, session_id: &str) -> Result<bool, String>

pub fn cleanup_finished(&self, older_than: Duration)

pub fn drain_completions(&self) -> Vec<BgCompletion>

pub fn drain_completions_for_session( &self, session_id: Option<&str>, ) -> Vec<BgCompletion>

pub fn has_completions_for_session(&self, session_id: Option<&str>) -> bool

pub fn ack_completions_for_session( &self, session_id: Option<&str>, task_ids: &[String], ) -> Vec<String>

pub fn pending_completions_for_session( &self, session_id: &str, ) -> Vec<BgCompletion>

pub fn detach(&self)

pub fn shutdown(&self)

Trait Implementations

impl Clone for BgTaskRegistry

fn clone(&self) -> BgTaskRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for BgTaskRegistry

fn default() -> Self

Returns the “default value” for a type.