Struct BlockingClient 

pub struct BlockingClient { /* private fields */ }

Implementations

impl BlockingClient

pub fn connect<T: ToSocketAddrs>(addr: T) -> Result<BlockingClient>

pub fn get(&mut self, key: &str) -> Result<Option<Bytes>>

pub fn set(&mut self, key: &str, value: Bytes) -> Result<()>

pub fn set_expires( &mut self, key: &str, value: Bytes, expiration: Duration, ) -> Result<()>

pub fn publish(&mut self, channel: &str, message: Bytes) -> Result<u64>

pub fn subscribe(self, channels: Vec<String>) -> Result<BlockingSubscriber>