Struct TaskDriver 

pub struct TaskDriver { /* private fields */ }

Manages in-flight task runs for a single camp.

Wrap in Arc to share across tasks; internal state is mutex-protected.

Implementations

impl TaskDriver

pub async fn new(store: Arc<TaskStore>) -> Result<Self, DriverError>

Create a driver backed by store, with no side-channels.

Immediately scans the store for Running runs left over from a prior daemon process and marks them Lost (“Lost-on-disappear”).

pub async fn with_channels( store: Arc<TaskStore>, channels: DriverChannels, ) -> Result<Self, DriverError>

Like new but wires the optional DriverChannels side-channels (completion notifications, live output tap).

pub async fn spawn_run( &self, cmd: &str, opts: SpawnOpts, ) -> Result<TaskRunId, DriverError>

Spawn cmd in a PTY and start capturing its output. Returns immediately with the new TaskRunId.

A beholder is selected via opts.beholder_select (default Auto). When a Rewriter beholder matches, its adjust_argv is applied to the command before spawning and the diff is recorded on beholder_status. When opts.tty_attached is true, Rewriter beholders decline in Auto mode to preserve human-readable output.

Output is written to the store as Stream::Stdout chunks (the PTY kernel merges stdout and stderr). Signal handling and status updates run in background tasks.

pub async fn resize_run( &self, id: &TaskRunId, cols: u16, rows: u16, ) -> Result<(), DriverError>

Resize a running task’s PTY and deliver SIGWINCH to the foreground process group (portable-pty’s resize does the ioctl, which is what signals the child).

Returns DriverError::NotFound when the run is not active on this driver instance — the same contract as TaskDriver::send_stdin.

pub async fn kill_run( &self, id: &TaskRunId, signal: Option<i32>, ) -> Result<(), DriverError>

Send signal to a running task. Defaults to SIGTERM (15).

For SIGTERM, the driver waits up to 5 seconds for the process to exit before escalating to SIGKILL. Returns DriverError::NotFound if the run is not active (already exited or launched on a different driver instance).

pub async fn send_stdin( &self, id: &TaskRunId, bytes: Vec<u8>, ) -> Result<(), DriverError>

Write bytes to the stdin of a running task (requires stdin_enabled).