Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Spawns tasks as OS processes and streams their output over a broadcast channel.

Lives on AppState on the main thread; all async work is delegated to Tokio task handles stored internally.

Implementations

impl TaskExecutor

pub fn new() -> Self

pub fn with_matcher_registry(matcher_registry: Arc<MatcherRegistry>) -> Self

Create a TaskExecutor that uses the given MatcherRegistry snapshot provider. This is used by AppState to ensure spawned tasks use the central ExtensionManager matcher set.

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

Subscribe to the live event stream.

Receivers are independent; a slow receiver simply misses old messages once the ring buffer wraps (broadcast semantics).

pub fn spawn( &mut self, task_id: TaskId, command: String, cancellation_token: CancellationToken, marker: String, log_store: Option<LogStore>, op_tx: &UnboundedSender<Vec<Operation>>, )

Start executing command in a background Tokio task.

• Broadcasts TaskEvent::Started immediately.
• Streams stdout and stderr as TaskEvent::ParsedOutput events, with raw bytes parsed through per-stream TerminalParser instances.
• Runs a DiagnosticsExtractor (shared between both streams) and sends Operation::AddIssue for each matched diagnostic line.
• Runs a MatcherEngine (separate instance per stream) for each set of extension-defined log matchers; emits Operation::AddIssue for every completed block and on end-of-stream flush.
• Watches cancellation_token; kills the process if it fires.
• Sends Operation::TaskFinished (or Cancelled) back through op_tx so the main loop can update the registry.

marker is the issue registry marker used for all extracted issues (typically "task:{queue}:{target}"). The caller is responsible for clearing stale issues with this marker before calling spawn.

matchers is the set of compiled log matchers contributed by loaded extensions. Pass an empty Vec when no extensions are active.

If log_store is provided, a dedicated log-writing sub-task subscribes to the broadcast channel and writes each line to .oo/cache/tasks/<task_id>.log, then compresses the file on completion.

pub fn abort(&mut self, task_id: TaskId)

Abort the async task for task_id, if one is running.

This does not update the registry — the caller is responsible for calling crate::task_registry::TaskRegistry::cancel before or after this.

Trait Implementations

impl Default for TaskExecutor

fn default() -> Self

Returns the “default value” for a type.