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 fn set_stream_degraded_callback( &self, cb: Option<Arc<dyn Fn(u64, String) + Send + Sync>>, )

Register a hook invoked on the first inbound overflow drop.

pub fn enable_heartbeat_tracking(&self) -> Arc<HeartbeatTracker>

Enable heartbeat tracking with the default 15s alive threshold.

pub fn enable_heartbeat_tracking_with_threshold( &self, threshold: Duration, ) -> Arc<HeartbeatTracker>

Enable heartbeat tracking with a custom alive threshold.

pub fn disable_heartbeat_tracking(&self)

Disable heartbeat tracking.

pub fn heartbeat_tracker(&self) -> Option<Arc<HeartbeatTracker>>

Current heartbeat tracker, if enabled.

pub fn is_daemon_alive(&self) -> bool

Whether the tracked daemon is considered alive (true if tracking disabled).

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 reconnect(&self) -> Result<()>

Re-dial and re-handshake after a connection drop.

Does not re-establish loop subscriptions; follow with Self::reattach_and_probe to resume a loop session.

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 loop_state_update( &self, loop_id: &str, state: Map<String, Value>, ) -> Result<Map<String, Value>>

loop_state_update.

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

loop_tree.

pub async fn loop_prune( &self, loop_id: &str, retention_days: Option<i32>, dry_run: bool, ) -> Result<Map<String, Value>>

loop_prune.

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

loop_delete.

pub async fn loop_detach(&self, subscription_id: &str) -> Result<()>

Detach from a loop by unsubscribing (subscription_id from loop_subscribe).

pub async fn authenticate( &self, access_key: &str, secret_key: &str, ) -> Result<Map<String, Value>>

Authenticate with access/secret keys.

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

Refresh auth token.

pub async fn job_create( &self, goal: &str, workspace: Option<&str>, ) -> Result<Map<String, Value>>

job_create on this long-lived connection.

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

job_status.

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

job_pause.

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

job_resume.

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

job_cancel.

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

job_dag.

pub async fn job_guidance( &self, job_id: &str, content: &str, goal_id: Option<&str>, ) -> Result<Map<String, Value>>

job_guidance.

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

autopilot_status.

pub async fn autopilot_submit( &self, description: &str, priority: i32, workspace: Option<&str>, ) -> Result<Map<String, Value>>

autopilot_submit.

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

autopilot_list_goals.

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

autopilot_get_goal.

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

autopilot_cancel_goal.

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

autopilot_cancel_all.

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

autopilot_wake.

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

autopilot_dream.

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

autopilot_resume.

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

autopilot_list_jobs.

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

autopilot_get_job.

pub async fn autopilot_subscribe(&self) -> Result<String>

Subscribe to autopilot_events (long-lived worker stream).

pub async fn autopilot_unsubscribe(&self, subscription_id: &str) -> Result<()>

Unsubscribe from an autopilot events subscription.

pub async fn cron_add( &self, text: &str, priority: Option<i32>, ) -> Result<Map<String, Value>>

cron_add.

pub async fn cron_list( &self, status: Option<&str>, ) -> Result<Map<String, Value>>

cron_list.

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

cron_show.

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

cron_cancel.

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

memory_stats.

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.