Struct TypedClient 

pub struct TypedClient<C, M> { /* private fields */ }

A strongly-typed view over any Client, carrying a StateMachine’s command/query/response types so callers work with real Rust values instead of postcard byte vectors.

let typed: TypedClient<RemoteClient, KvMachine> = TypedClient::new(remote);
let resp = typed.propose(&KvCommand::Set { key, value }).await?;

Implementations

impl<C, M> TypedClient<C, M>

pub fn new(inner: C) -> Self

Wrap a raw Client with M’s types.

pub fn inner(&self) -> &C

Borrow the underlying raw client.

pub fn into_inner(self) -> C

Unwrap back to the raw client.

impl<C: Client, M: StateMachine> TypedClient<C, M>

pub async fn propose( &self, command: &M::Command, ) -> Result<M::Response, ClientError>

Propose a typed command and decode the typed response.

Errors

ClientError::Codec if the command cannot be encoded or the response cannot be decoded, otherwise any error from the underlying Client.

pub async fn query(&self, query: &M::Query) -> Result<M::Response, ClientError>

Run a typed linearizable query and decode the typed response.

Errors

ClientError::Codec if the query cannot be encoded or the response cannot be decoded, otherwise any error from the underlying Client.

impl<C: KeyedClient, M: StateMachine> TypedClient<C, M>

pub async fn propose_keyed( &self, key: &[u8], command: &M::Command, ) -> Result<M::Response, ClientError>

Propose a typed command to the Raft group that owns key.

Errors

ClientError::Codec if the command cannot be encoded or the response cannot be decoded, otherwise any error from the underlying KeyedClient.

pub async fn query_keyed( &self, key: &[u8], query: &M::Query, ) -> Result<M::Response, ClientError>

Run a typed linearizable query against the Raft group that owns key.

Errors

ClientError::Codec if the query cannot be encoded or the response cannot be decoded, otherwise any error from the underlying KeyedClient.