Struct CalibandClient 

pub struct CalibandClient { /* private fields */ }

A client bound to one caliband control endpoint (Unix, or TCP+TLS+token).

Implementations

impl CalibandClient

pub fn new(socket_path: impl Into<PathBuf>) -> Self

Create a client for a local Unix control socket (credential-free default).

pub fn connect_tcp( addr: impl Into<String>, tls: Option<TlsClient>, token: Option<String>, ) -> Self

Create a client that dials a TCP control endpoint over TLS + bearer token (ADR 0051). tls/token are None only in plaintext/no-auth test setups.

pub fn endpoint(&self) -> &Endpoint

The control endpoint this client targets.

pub async fn request(&self, req: &CtlRequest) -> Result<CtlReply>

Send one request and return the raw reply, surfacing Error replies as typed CoreErrors.

pub async fn list(&self) -> Result<Vec<AgentRecord>>

List all agents registered with this daemon.

pub async fn spawn(&self, spec: SpawnSpec) -> Result<(String, Endpoint)>

Spawn a new agent; returns (id, per-agent endpoint).

pub async fn attach(&self, id: impl Into<String>) -> Result<Endpoint>

Resolve an agent’s per-agent endpoint for attaching.

pub async fn kill(&self, id: impl Into<String>) -> Result<()>

Kill an agent.

pub async fn respawn(&self, id: impl Into<String>) -> Result<String>

Respawn an agent; returns the new id.

pub async fn rm(&self, id: impl Into<String>, force: bool) -> Result<()>

Remove an agent from the registry.

pub async fn status(&self) -> Result<DaemonStatus>

Probe daemon status.

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

Ask the daemon to drain and shut down.

pub async fn open_stream( &self, endpoint: &Endpoint, ) -> Result<BufReader<BoxConn>>

Open a streaming reader over a per-agent endpoint (from Self::attach), dialing with this client’s TLS/token. Lines read from this reader are caliban stream-json frames.

pub async fn send_inbound( &self, endpoint: &Endpoint, frame: &AttachInbound, ) -> Result<()>

Write a single inbound control frame to an interactive agent’s per-agent endpoint (from Self::attach). Opens a fresh write-only connection, matching caliban’s “all attach connections feed a shared inbox” model.

Trait Implementations

impl Clone for CalibandClient

fn clone(&self) -> CalibandClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.