Struct BgTaskRegistry 

pub struct BgTaskRegistry { /* private fields */ }

Implementations

impl BgTaskRegistry

pub fn new(progress_sender: SharedProgressSender) -> Self

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

where F: Fn(&str, String) -> String + 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 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 replay_session( &self, storage_dir: &Path, session_id: &str, ) -> Result<(), String>

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 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 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.