Struct ControlClient 

pub struct ControlClient { /* private fields */ }

The client half of the control transport: connects to the daemon’s control socket (resolved from a ControlId), sends one ControlRequest, and reads back its ControlResponse. A fresh connection per request keeps it simple and stateless.

Implementations

impl ControlClient

pub fn new(id: impl Into<ControlId>) -> Self

A client for the control socket identified by id, with no token.

Only reaches a daemon that runs without one, which in practice means a test driving the protocol directly. Real callers use with_token - see ControlToken.

pub fn with_token(self, token: ControlToken) -> Self

Present token on every connection this client opens.

pub fn for_home(id: impl Into<ControlId>, dir: &Path) -> Self

A client that reads the daemon’s token out of dir.

A missing token file is not an error here. It has two very different causes - no daemon is running, or one is running that predates tokens - and the client cannot tell them apart, while the daemon can. Refusing to even construct a client would make the second case unrecoverable: an upgraded CLI could not ask the still-running pre-token daemon to shut down, so it could neither stop it nor start a replacement, and the error it printed (“Is the daemon running? Start it with lev daemon start”) would be advice the user was already following.

The daemon is the enforcer. A client with no token connects, is refused if the daemon requires one, and reports that - which is accurate.

pub async fn request(&self, req: &ControlRequest) -> Result<ControlResponse>

Send one request and await its response. Errors if the daemon can’t be reached, does not answer within request_timeout, the connection closes before a reply, or the reply doesn’t parse.

pub async fn spawn(&self, args: SpawnArgs) -> Result<ControlResponse>

Spawn a new agent.

pub async fn status(&self, run_id: &str) -> Result<ControlResponse>

Query a run’s status.

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

List every known live run.

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

Ask the daemon to shut down.

pub async fn subscribe(&self) -> Result<WorldEventStream>

Open a pushed event stream: connect, send Subscribe, and return a reader that yields WorldEvents until the daemon closes the connection. The HTTP/WS gateway uses this instead of polling.

Trait Implementations

impl Clone for ControlClient

fn clone(&self) -> ControlClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.