Struct RpcClient 

pub struct RpcClient { /* private fields */ }

An RPC v1 client targeting a single ralph-api server.

Implementations

impl RpcClient

pub fn new(base_url: &str) -> Result<Self>

Create a new client pointed at the given base URL.

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

Issue an RPC call and return the result value.

pub async fn task_list(&self) -> Result<Vec<TaskRecord>>

Fetch all tasks.

pub async fn loop_list(&self) -> Result<Vec<LoopRecord>>

Fetch all loops.

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

Fetch config.

pub async fn stream_subscribe( &self, topics: &[&str], cursor: Option<&str>, ) -> Result<SubscribeResult>

Create a stream subscription, returning the subscription ID and cursor.

pub fn stream_ws_url(&self, subscription_id: &str) -> Result<String>

Build the WebSocket URL for the given subscription ID.

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

Send a stream.ack to checkpoint the cursor.

Trait Implementations

impl Clone for RpcClient

fn clone(&self) -> RpcClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.