Struct LoggingRunner 

pub struct LoggingRunner<R: ProcessRunner = JobRunner> { /* private fields */ }

A ProcessRunner decorator that reports every command it runs to a CommandObserver, then forwards the real runner’s result unchanged.

It adds only observation — the wrapped runner’s behaviour, results, and errors are passed through verbatim. Construct one with new (a StderrObserver) or with_observer (a custom sink), then hand it to any client’s with_runner builder:

use processkit::JobRunner;
use vcs_cli_support::logging::LoggingRunner;
// A boxed runner erases the concrete type, so the same client type works
// whether or not logging is enabled.
let runner: Box<dyn processkit::ProcessRunner> =
    Box::new(LoggingRunner::new(JobRunner::new(), "vcs-mcp"));

Implementations

impl<R: ProcessRunner> LoggingRunner<R>

pub fn new(inner: R, tag: impl Into<Arc<str>>) -> Self

Wrap inner, logging each command to stderr with the tag tag (via StderrObserver).

pub fn with_observer(inner: R, observer: Arc<dyn CommandObserver>) -> Self

Wrap inner, reporting each command to observer.

pub fn observer(&self) -> &Arc<dyn CommandObserver>

The observer this runner reports to.

pub fn inner(&self) -> &R

A reference to the wrapped runner.

Trait Implementations

impl<R: ProcessRunner + Debug> Debug for LoggingRunner<R>

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

Formats the value using the given formatter.

impl<R: ProcessRunner> ProcessRunner for LoggingRunner<R>

fn output_string<'life0, 'life1, 'async_trait>( &'life0 self, command: &'life1 Command, ) -> Pin<Box<dyn Future<Output = Result<ProcessResult<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run command to completion, capturing stdout/stderr and the exit code. A non-zero exit is reported in the result, not raised.

fn output_bytes<'life0, 'life1, 'async_trait>( &'life0 self, command: &'life1 Command, ) -> Pin<Box<dyn Future<Output = Result<ProcessResult<Vec<u8>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Run command to completion, capturing stdout as raw bytes (output_string captures it as lossy-UTF-8 text); stderr is still text. For binary tools — git cat-file, tar -c, an image transcoder — whose stdout is not UTF-8.

fn start<'life0, 'life1, 'async_trait>( &'life0 self, command: &'life1 Command, ) -> Pin<Box<dyn Future<Output = Result<RunningProcess>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start command and return a live RunningProcess for streaming, readiness probes, or incremental consumption.