Struct Redis

pub struct Redis { /* private fields */ }

Implementations

impl Redis

pub async fn new() -> RedisResult<Self>

pub async fn ping(&self) -> RedisResult<()>

Methods from Deref<Target = Pool<RedisConnectionManager>>

pub async fn get( &self, ) -> Result<PooledConnection<'_, M>, RunError<<M as ManageConnection>::Error>>

Retrieves a connection from the pool.

pub async fn get_owned( &self, ) -> Result<PooledConnection<'static, M>, RunError<<M as ManageConnection>::Error>>

Retrieves an owned connection from the pool

Using an owning PooledConnection makes it easier to leak the connection pool. Therefore, Pool::get (which stores a lifetime-bound reference to the pool) should be preferred whenever possible.

pub async fn dedicated_connection( &self, ) -> Result<<M as ManageConnection>::Connection, <M as ManageConnection>::Error>

Get a new dedicated connection that will not be managed by the pool. An application may want a persistent connection (e.g. to do a postgres LISTEN) that will not be closed or repurposed by the pool.

This method allows reusing the manager’s configuration but otherwise bypassing the pool

pub fn state(&self) -> State

Returns information about the current state of the pool.

pub fn add( &self, conn: <M as ManageConnection>::Connection, ) -> Result<(), AddError<<M as ManageConnection>::Connection>>

Adds a connection to the pool.

If the connection is broken, or the pool is at capacity, the connection is not added and instead returned to the caller in Err.

Trait Implementations

impl Clone for Redis

fn clone(&self) -> Redis

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Deref for Redis

type Target = Pool<RedisConnectionManager>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl InstanceTrait for Redis

type Error = Error

fn register<'life0, 'async_trait>( _: &'life0 Container, ) -> Pin<Box<dyn Future<Output = Result<Self, ContainerError>> + Send + 'async_trait>>

where Self: Sized + 'async_trait, 'life0: 'async_trait,

fn boot<'async_trait>() -> Pin<Box<dyn Future<Output = Result<(), ContainerError>> + Send + 'async_trait>>

where Self: Sized + 'async_trait,

fn name() -> String

fn cleanup() -> Result<(), ContainerError>

fn facade() -> &'static Self

where Self: Sized,