Struct KvClient 

pub struct KvClient { /* private fields */ }

Key-value store client interface

Implements CRUD operations with configurable consistency levels. All write operations use strong consistency.

Implementations

impl KvClient

pub async fn put( &self, key: impl AsRef<[u8]>, value: impl AsRef<[u8]>, ) -> Result<(), ClientApiError>

Stores a value with strong consistency

Errors

• crate::ClientApiError::Network on network failures
• [crate::ClientApiError::InvalidResponse] for malformed server responses

pub async fn delete(&self, key: impl AsRef<[u8]>) -> Result<(), ClientApiError>

Deletes a key with strong consistency guarantees

Permanently removes the specified key and its associated value from the store.

Parameters

• key: The byte-serialized key to delete. Supports any type implementing AsRef<[u8]> (e.g. String, &str, Vec<u8>)

Errors

• [Error::FailedToSendWriteRequestError] if unable to reach the leader node
• [Error::InvalidResponse] for malformed server responses

pub async fn get( &self, key: impl AsRef<[u8]>, linear: bool, ) -> Result<Option<ClientResult>, ClientApiError>

Retrieves a single key’s value from the cluster

Parameters

• key: The key to retrieve, accepts any byte slice compatible type
• linear: Whether to use linearizable read consistency

Returns

• Ok(Some(ClientResult)) if key exists
• Ok(None) if key not found
• Err on network failures or invalid responses

pub async fn get_multi( &self, keys: impl IntoIterator<Item = impl AsRef<[u8]>>, linear: bool, ) -> Result<Vec<Option<ClientResult>>, ClientApiError>

Fetches values for multiple keys from the cluster

Parameters

• keys: Iterable collection of keys to fetch
• linear: Whether to use linearizable read consistency

Returns

Ordered list of results matching input keys. Missing keys return None.

Errors

• Error::EmptyKeys if no keys provided
• Error::FailedToSendReadRequestError on network failures

Trait Implementations

impl Clone for KvClient

fn clone(&self) -> KvClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.