Struct SimpleClient 

pub struct SimpleClient {
    pub codec: Codec,
    pub io: RefCell<Option<TcpStream>>,
}

Redis client

Fields

codec: Codec

io: RefCell<Option<TcpStream>>

Implementations

impl SimpleClient

pub fn new(io: TcpStream) -> Self

Create new simple client

pub fn exec<U>(&self, cmd: U) -> Result<U::Output, CommandError>

where U: Command,

Execute redis command

pub fn encode<U: Command>(&self, cmd: U) -> Result<BytesMut, Error>

pub fn encode_req(&self, req: Request, buf: &mut BytesMut) -> Result<(), Error>

pub fn send(&self, arg: &BytesMut) -> Result<Response, CommandError>

pub fn decode<U>(&self, resp: Response) -> Result<U::Output, CommandError>

where U: Command,

pub fn is_closed(&self) -> bool

Trait Implementations

impl Send for SimpleClient

impl Sync for SimpleClient