Struct StreamingExec 

pub struct StreamingExec { /* private fields */ }

Handle for reading streaming exec events.

Reads frames from the exec server: Data frames contain ExecChunk (stdout/stderr), Control frames contain ExecExit (final exit code).

Implementations

impl StreamingExec

pub fn input(&self) -> StreamingExecInput

Return a cloneable input handle for this running stream.

pub async fn write_stdin(&self, data: &[u8]) -> Result<()>

Write bytes to the running command’s stdin.

pub async fn close_stdin(&self) -> Result<()>

Close the running command’s stdin without stopping the process.

pub async fn flush(&self) -> Result<()>

Request a flush of the guest’s buffered output (see StreamingExecInput::flush).

pub async fn next_event(&mut self) -> Result<Option<ExecEvent>>

Read the next event from the stream.

Returns None when the command has exited and all output has been read.

pub async fn cancel(&mut self) -> Result<()>

Request cancellation of the running streaming exec workload.

The guest exec server treats this as a best-effort container stop signal and should emit a final exit frame after terminating the child process.

pub async fn collect(self) -> Result<(ExecOutput, ExecMetrics)>

Collect all remaining output and return the final result with metrics.

Consumes the stream, buffering all stdout/stderr until the command exits.

pub fn is_done(&self) -> bool

Whether the stream has finished (command exited or connection closed).

pub fn metrics(&self) -> ExecMetrics

Get execution metrics so far.

Trait Implementations

impl Debug for StreamingExec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.