Struct ntex_redis::Client

pub struct Client { /* fields omitted */ }

Shared redis client

Implementations

impl Client

pub fn exec<T>(
    &self,
    cmd: T
) -> impl Future<Output = Result<T::Output, CommandError>> where
    T: Command, 

Execute redis command

pub async fn flushdb(&self) -> Result<(), Error>

Delete all the keys of the currently selected DB.

pub fn is_connected(&self) -> bool

Returns true if underlying transport is connected to redis

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Service for Client

type Request = Request

Requests handled by the service.

type Response = Response

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<CommandResult, Ready<Response, Error>>

The future response value.

fn poll_ready(&self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Ready when the service is able to process requests.

fn call(&self, req: Request) -> Self::Future

Process the request and return the response asynchronously.

pub fn poll_shutdown(&self, ctx: &mut Context<'_>, is_error: bool) -> Poll<()>

Shutdown service.

pub fn map<F, R>(self, f: F) -> Map<Self, F, R> where
    F: FnMut(Self::Response) -> R, 

Map this service’s output to a different type, returning a new service of the resulting type.

pub fn map_err<F, E>(self, f: F) -> MapErr<Self, F, E> where
    F: Fn(Self::Error) -> E, 

Map this service’s error to a different error, returning a new service.