Struct Client 

pub struct Client { /* private fields */ }

Long-lived protocol-1 WebSocket client.

Implementations

impl Client

pub fn new(url: impl Into<String>) -> Self

Create a client for url.

pub fn with_config(cfg: ClientConfig) -> Self

Create with explicit config.

pub fn url(&self) -> &str

Daemon URL.

pub fn is_connected(&self) -> bool

Whether the socket is connected.

pub fn is_connection_alive(&self) -> bool

Whether the reader task is alive.

pub fn inbound_dropped(&self) -> u64

Count of dropped inbound frames under backpressure.

pub async fn disconnect_cause(&self) -> Option<DisconnectCause>

Disconnect cause if disconnected.

pub async fn wait_disconnected(&self) -> DisconnectCause

Wait until disconnected.

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

Dial + handshake (connection_init / connection_ack ready).

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

Close the connection.

pub async fn send_envelope(&self, env: Envelope) -> Result<()>

Send a raw envelope.

pub async fn notify( &self, method: &str, params: Map<String, Value>, ) -> Result<()>

Fire-and-forget notification.

pub async fn request( &self, method: &str, params: Map<String, Value>, req_timeout: Duration, ) -> Result<Map<String, Value>>

RPC request correlated by id.

pub async fn request_response( &self, payload: Map<String, Value>, fallback_method: &str, req_timeout: Duration, ) -> Result<Map<String, Value>>

Legacy-shaped request map (type → method) like Go RequestResponse.

pub async fn subscribe( &self, method: &str, params: Map<String, Value>, req_timeout: Duration, ) -> Result<String>

Subscribe; returns subscription id.

pub async fn unsubscribe(&self, id: &str) -> Result<()>

Unsubscribe by id.

pub async fn read_event(&self) -> Result<Option<Value>>

Read next inbound app event (blocks).

pub async fn read_event_with_timeout( &self, dur: Duration, ) -> Result<Option<Value>>

Read with timeout; None on timeout.

pub async fn clear_pending_events(&self)

Clear pending inbound events.

pub async fn peel_stale_pending_control_events(&self) -> Vec<String>

Peel stale pending control frames at turn start.

pub async fn send_input(&self, text: &str, opts: SendInputOptions) -> Result<()>

Notify loop_input.

pub async fn loop_new( &self, params: Map<String, Value>, ) -> Result<Map<String, Value>>

loop_new RPC.

pub async fn loop_list(&self, limit: u32) -> Result<Map<String, Value>>

loop_list.

pub async fn loop_get(&self, loop_id: &str) -> Result<Map<String, Value>>

loop_get.

pub async fn loop_reattach(&self, loop_id: &str) -> Result<Map<String, Value>>

loop_reattach.

pub async fn loop_subscribe( &self, loop_id: &str, stream_delivery: &str, ) -> Result<String>

Subscribe to loop_events.

pub async fn loop_cards_fetch( &self, loop_id: &str, ) -> Result<Map<String, Value>>

loop_cards_fetch.

pub async fn loop_history_fetch( &self, loop_id: &str, ) -> Result<Map<String, Value>>

loop_history_fetch.

pub async fn loop_messages( &self, loop_id: &str, limit: u32, offset: u32, ) -> Result<Map<String, Value>>

loop_messages.

pub async fn loop_state_get(&self, loop_id: &str) -> Result<Map<String, Value>>

loop_state_get.

pub async fn list_skills(&self) -> Result<Map<String, Value>>

skills_list.

pub async fn list_models(&self) -> Result<Map<String, Value>>

models_list.

pub async fn mcp_status(&self) -> Result<Map<String, Value>>

mcp_status.

pub async fn fetch_daemon_status(&self) -> Result<Map<String, Value>>

daemon_status.

pub async fn invoke_skill( &self, skill: &str, args: &str, ) -> Result<Map<String, Value>>

invoke_skill on this connection (stream socket for turn enqueue).

pub async fn reattach_and_probe(&self, loop_id: &str) -> Result<()>

Reattach + subscribe + loop_get probe.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.