Struct RedisSink 

pub struct RedisSink<Args, Encode, Conn = ConnectionManager> { /* private fields */ }

A Redis sink that batches task pushes to Redis.

Implementations

impl<Args, Conn: Clone, Encode> RedisSink<Args, Encode, Conn>

pub fn new(conn: &Conn, config: &RedisConfig) -> Self

Creates a new Redis sink.

Trait Implementations

impl<Args, Conn: Clone, Cdc: Clone> Clone for RedisSink<Args, Cdc, Conn>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Args: Debug, Encode: Debug, Conn: Debug> Debug for RedisSink<Args, Encode, Conn>

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

Formats the value using the given formatter.