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<()>

Errors

• Error::FailedToSendWriteRequestError on network failures
• Error::InvalidResponse for malformed server responses

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

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>>

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>>>

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