Struct ProcessSupervisor 

pub struct ProcessSupervisor { /* private fields */ }

Run-scoped owner and observer for pipe and PTY execution resources.

Implementations

impl ProcessSupervisor

pub fn new(max_output_bytes: usize) -> Result<Self, ExecProcessError>

pub fn new_with_runtime_temp_root( max_output_bytes: usize, root: impl AsRef<Path>, ) -> Result<Self, ExecProcessError>

Use a stable, private Host directory so execution policy identities can survive Host restart. The root must be outside all workspace roots. Its parent must already exist; Run children are exclusively created.

pub fn runtime_temp_root(&self) -> &Path

Host policy and exec Tool restrictions must explicitly grant read/write access to this root. Each dispatched sandbox receives only its Run child.

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

pub async fn spawn( &self, spec: ExecSpawnSpec, ) -> Result<ExecSessionId, ExecProcessError>

pub async fn write_and_poll( &self, run_id: &RunId, session_id: ExecSessionId, input: Option<&str>, wait: Duration, cancellation: &CancellationToken, ) -> Result<ExecPollResult, ExecProcessError>

Use output waits for TTY/input interactions and completion waits for empty pipe observations. The duration bounds this observation only.

pub async fn write_and_poll_with_options( &self, run_id: &RunId, session_id: ExecSessionId, input: Option<&str>, options: ExecWaitOptions, cancellation: &CancellationToken, ) -> Result<ExecPollResult, ExecProcessError>

Observe one existing session with an explicit wait strategy. Yielding preserves both the process and its Run-scoped authority.

pub async fn close( &self, run_id: &RunId, session_id: ExecSessionId, ) -> Result<(), ExecProcessError>

pub async fn close_run(&self, run_id: &RunId) -> Result<usize, ExecProcessError>

pub fn list( &self, run_id: &RunId, ) -> Result<Vec<ExecSessionId>, ExecProcessError>

pub fn snapshot( &self, run_id: &RunId, session_id: ExecSessionId, ) -> Result<ExecSessionSnapshot, ExecProcessError>

pub fn operation_plan( &self, run_id: &RunId, session_id: ExecSessionId, ) -> Result<ToolOperationPlan, ExecProcessError>