Struct ntex_redis::RedisConnector

pub struct RedisConnector<A, T> { /* fields omitted */ }

Redis connector

Implementations

impl<A> RedisConnector<A, ()> where
    A: Address + Clone, 

pub fn new(address: A) -> RedisConnector<A, Connector<A>>

Create new redis connector

impl<A, T> RedisConnector<A, T> where
    A: Address + Clone,
    T: Service<Request = Connect<A>, Error = ConnectError>,
    T::Response: AsyncRead + AsyncWrite + Unpin + 'static, 

pub fn password<U>(self, password: U) -> Self where
    U: AsRef<str>, 

Add redis auth password

pub fn buffer_params(
    self,
    max_read_buf_size: u16,
    max_write_buf_size: u16,
    min_buf_size: u16
) -> Self

Set read/write buffer params

By default read buffer is 16kb, write buffer is 16kb

pub fn connector<U>(self, connector: U) -> RedisConnector<A, U> where
    U: Service<Request = Connect<A>, Error = ConnectError>,
    U::Response: AsyncRead + AsyncWrite + Unpin + 'static, 

Use custom connector

pub fn connect(&self) -> impl Future<Output = Result<Client, ConnectError>>

Connect to redis server and create shared client

pub fn connect_simple(
    &self
) -> impl Future<Output = Result<SimpleClient, ConnectError>>

Connect to redis server and create simple client