Struct ntex_redis::RedisConnector

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

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,

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

Add redis auth password

pub fn memory_pool(self, id: PoolId) -> Self

Set memory pool.

Use specified memory pool for memory allocations. By default P7 memory pool is used.

pub fn connector<U>(self, connector: U) -> RedisConnector<A, U>where
    U: Service<Connect<A>, Error = ConnectError>,
    IoBoxed: From<U::Response>,

Use custom connector

impl<A, T> RedisConnector<A, T>where
    A: Address + Clone,
    T: Service<Connect<A>, Error = ConnectError>,
    IoBoxed: From<T::Response>,

pub async fn connect(&self) -> Result<Client, ConnectError>

Connect to redis server and create shared client

pub async fn connect_simple(&self) -> Result<SimpleClient, ConnectError>

Connect to redis server and create simple client