Struct ConnectionHandler 

pub struct ConnectionHandler<N: TcpConnect, P: Protocol>
where
    HelloCommand: Command<<P as Protocol>::FrameType>,
{ /* private fields */ }

Configuration and connection factory for Redis clients.

Each call to connect creates a new connection. The returned client owns the connection, which is closed by the embedded-nal-async implementation when it is dropped.

Implementations

impl<N: TcpConnect> ConnectionHandler<N, Resp2>

pub fn resp2(remote: SocketAddr) -> Self

Creates a new connection handler using RESP2 protocol

impl<N: TcpConnect> ConnectionHandler<N, Resp3>

pub fn resp3(remote: SocketAddr) -> Self

Creates a new connection handler using RESP3 protocol

impl<N: TcpConnect, P: Protocol> ConnectionHandler<N, P>

where AuthCommand: Command<<P as Protocol>::FrameType>, HelloCommand: Command<<P as Protocol>::FrameType>, PingCommand: Command<<P as Protocol>::FrameType>, <P as Protocol>::FrameType: ToStringOption + From<CommandBuilder>,

pub async fn connect<'a, C: Clock>( &self, network: &'a N, clock: Option<&'a C>, ) -> Result<Client<'a, N::Connection<'a>, C, P>, ConnectionError>

Opens, authenticates and returns a Redis client.

impl<N: TcpConnect, P: Protocol> ConnectionHandler<N, P>

where HelloCommand: Command<<P as Protocol>::FrameType>,

pub fn timeout(&mut self, timeout: Microseconds) -> &mut Self

Sets the max. duration waiting for Redis responses

pub fn auth(&mut self, credentials: Credentials) -> &mut Self

Sets the authentication credentials

pub fn use_ping(&mut self) -> &mut Self

Uses a PING command to verify newly created connections

pub fn memory(&mut self, parameters: MemoryParameters) -> &mut Self

Sets memory allocation parameters