Struct RemoteClient 

pub struct RemoteClient { /* private fields */ }

A remote client that talks to a crafty cluster over any Transport (live QUIC/HTTP/3 in production, the in-memory LocalNetwork in tests).

A client may contact any node: a follower transparently forwards to the leader server-side (client-routing), so a single reachable node is enough. The client is nonetheless configured with several targets and a RetryPolicy so it survives a node being down or an election in flight — it rotates across targets, and follows a NotLeader hint straight to the named leader when one is returned.

Implementations

impl RemoteClient

pub fn new( transport: Arc<dyn Transport>, targets: impl IntoIterator<Item = NodeId>, ) -> Self

Build a client over transport that contacts targets (seed node ids; the transport resolves each to an address). Uses the default RetryPolicy.

pub fn with_retry(self, retry: RetryPolicy) -> Self

Override the RetryPolicy.

pub fn targets(&self) -> &[NodeId]

The seed nodes this client rotates across.

Trait Implementations

impl Client for RemoteClient

fn propose( &self, payload: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Submit a write. payload is the application-encoded command; the returned bytes are the application-encoded response.

fn query( &self, payload: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Submit a linearizable read (ReadIndex, read-consistency). payload is the application-encoded query; the returned bytes are the encoded response.

impl KeyedClient for RemoteClient

fn propose_keyed( &self, key: Vec<u8>, payload: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Submit a write to the Raft group owning key.

fn query_keyed( &self, key: Vec<u8>, payload: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Submit a linearizable read against the Raft group owning key.

impl TwoPhaseClient for RemoteClient

fn prepare_keyed( &self, tx_id: Vec<u8>, key: Vec<u8>, command: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Stage a command on the shard for key under tx_id.

fn commit_keyed( &self, tx_id: Vec<u8>, key: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Commit a previously prepared command.

fn abort_keyed( &self, tx_id: Vec<u8>, key: Vec<u8>, ) -> impl Future<Output = Result<Vec<u8>, ClientError>> + Send

Abort a prepared command and release staging state.