Struct AsyncCommandClient 

pub struct AsyncCommandClient { /* private fields */ }

Async one-shot RPC client (connect → RPC → close).

Implementations

impl AsyncCommandClient

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

Create against ws_url with default 30s timeout.

pub fn with_timeout(self, timeout: Duration) -> Self

Override timeout.

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

Generic request.

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

job_create.

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 cron_add( &self, text: &str, priority: Option<i32>, ) -> Result<Map<String, Value>>

cron_add (normalized to {"job": {...}} when possible).

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.

Trait Implementations

impl Clone for AsyncCommandClient

fn clone(&self) -> AsyncCommandClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncCommandClient

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

Formats the value using the given formatter.