Struct RpcClient 

pub struct RpcClient<R, W> { /* private fields */ }

Implementations

impl RpcClient<OwnedReadHalf<TcpStream>, OwnedWriteHalf<TcpStream>>

pub async fn connect_tcp( addr: impl ToSocketAddrsAsync, hashname: u64, ) -> Result<Self>

pub async fn connect_tcp_by_name( addr: impl ToSocketAddrsAsync, name: &str, ) -> Result<Self>

impl RpcClient<OwnedReadHalf<UnixStream>, OwnedWriteHalf<UnixStream>>

pub async fn connect_uds(path: impl AsRef<Path>, hashname: u64) -> Result<Self>

pub async fn connect_uds_by_name( path: impl AsRef<Path>, name: &str, ) -> Result<Self>

impl<R: AsyncRead + Unpin + 'static, W: AsyncWrite + Unpin + 'static> RpcClient<R, W>

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

pub async fn contains(&mut self, key: &[u8]) -> Result<Option<u32>>

pub async fn first(&mut self) -> Result<Option<(Vec<u8>, Vec<u8>)>>

pub async fn last(&mut self) -> Result<Option<(Vec<u8>, Vec<u8>)>>

pub async fn range( &mut self, start: Bound<Vec<u8>>, end: Bound<Vec<u8>>, ) -> Result<Vec<(Vec<u8>, Vec<u8>)>>

pub async fn range_keys( &mut self, start: Bound<Vec<u8>>, end: Bound<Vec<u8>>, ) -> Result<Vec<Vec<u8>>>

pub async fn upsert( &mut self, key: UpsertKey, flag: Option<bool>, value: Vec<u8>, ) -> Result<Vec<u8>>

pub async fn remove(&mut self, key: &[u8], soft: bool) -> Result<()>

pub async fn take(&mut self, key: &[u8], soft: bool) -> Result<Option<Vec<u8>>>

pub async fn count(&mut self, exact: bool) -> Result<u64>

pub async fn apply_batch( &mut self, items: Vec<(Vec<u8>, Option<Vec<u8>>)>, ) -> Result<()>