Struct BobHarness 

pub struct BobHarness;

bob CLI as a Harness. Delegates to the bob_rs SDK; this is just the neutral face over it.

Implementations

impl BobHarness

pub fn new() -> Self

Trait Implementations

impl Clone for BobHarness

fn clone(&self) -> BobHarness

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BobHarness

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

Formats the value using the given formatter.

impl Default for BobHarness

fn default() -> BobHarness

Returns the “default value” for a type.

impl Harness for BobHarness

fn info(&self) -> HarnessInfo

Static metadata for the UI.

fn readiness(&self) -> HarnessReadiness

Probe availability / version / auth. May shell out; callers should treat it as blocking and run it off the UI thread.

fn install(&self, on_event: InstallCallback) -> Result<(), HarnessError>

Stream a one-time install. Harnesses that need no install (e.g. a hosted-API adapter) return Ok(()) immediately.

fn run( &self, request: RunRequest, on_event: RunCallback, ) -> Result<RunHandle, HarnessError>

Start a run, streaming events through on_event. Returns a handle immediately; work continues on background threads.

fn credential(&self) -> CredentialSpec

The credential this harness needs.

fn login(&self, _on_event: InstallCallback) -> Result<(), HarnessError>

Trigger the harness’s own interactive sign-in (its CLI’s OAuth), streaming progress as InstallEvents — the same subprocess stream shape as install. The flow opens the user’s browser; this blocks until the login process exits, then Done { ok } reports success. Default: unsupported — harnesses that Compose authenticates itself (bob, via its API key) keep it.

fn run_channel( &self, request: RunRequest, ) -> Result<(RunHandle, Receiver<RunEvent>), HarnessError>

Convenience over run for callers that want to pull events off a channel instead of supplying a push callback. Forwards each RunEvent into an mpsc channel and hands the receiver back alongside the run handle, so the caller can simply for event in rx { … } rather than re-write the Arc::new(move |ev| tx.send(ev)) plumbing at every call site.