Struct IpcClient 

pub struct IpcClient { /* private fields */ }

Client for connecting to an IPC server

Implementations

impl IpcClient

pub fn connect<P: AsRef<Path>>(socket_path: P) -> Result<Self>

Connect to an IPC server

pub fn connect_with_timeout<P: AsRef<Path>>( socket_path: P, timeout: Duration, ) -> Result<Self>

Connect with timeout

pub fn ping(&mut self) -> Result<Duration>

Ping the server

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

Put a key-value pair

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

Get a value by key

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

Delete a key

pub fn begin_txn(&mut self) -> Result<u64>

Begin a transaction, returns transaction ID

pub fn commit_txn(&mut self, txn_id: u64) -> Result<u64>

Commit a transaction, returns commit timestamp

pub fn abort_txn(&mut self, txn_id: u64) -> Result<()>

Abort a transaction

pub fn put_path(&mut self, path: &[&str], value: &[u8]) -> Result<()>

Put by hierarchical path

pub fn get_path(&mut self, path: &[&str]) -> Result<Option<Vec<u8>>>

Get by hierarchical path

pub fn checkpoint(&mut self) -> Result<()>

Force a checkpoint

pub fn stats(&mut self) -> Result<HashMap<String, u64>>

Get server statistics