Struct KvClient 

pub struct KvClient { /* private fields */ }

KV client with automatic leader tracking and retry with exponential backoff.

Implementations

impl KvClient

pub fn new(nodes: HashMap<NodeId, String>) -> Self

pub async fn get(&mut self, key: &[u8]) -> Result<GetResponse, Status>

pub async fn put( &mut self, key: &[u8], value: &[u8], ) -> Result<PutResponse, Status>

pub async fn put_with_options( &mut self, key: &[u8], value: &[u8], lease_id: i64, ttl_seconds: i64, ) -> Result<PutResponse, Status>

pub async fn delete(&mut self, key: &[u8]) -> Result<DeleteResponse, Status>

pub async fn range( &mut self, start_key: &[u8], end_key: &[u8], limit: i64, ) -> Result<RangeResponse, Status>