Struct CellClient 

pub struct CellClient { /* private fields */ }

Implementations

impl CellClient

pub fn connect(socket_path: &str) -> Result<Self>

pub fn connect_to_service(service_name: &str) -> Result<Self>

pub fn connect_with_batch(socket_path: &str, batch_size: usize) -> Result<Self>

pub fn call(&mut self, payload: &[u8]) -> Result<Vec<u8>>

pub fn queue_request(&mut self, payload: &[u8]) -> Result<bool>

Specialized method for pipelining. Queues a request into the buffer. Returns true if flushed.

pub fn read_n_responses(&mut self, n: usize) -> Result<()>

Reads N responses from the socket.

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