Struct RedisAck 

pub struct RedisAck<Conn = ConnectionManager, Encode = JsonCodec<Vec<u8>>> { /* private fields */ }

A Redis acknowledgment Layer

Implementations

impl<Conn: Clone, Encode> RedisAck<Conn, Encode>

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

Creates a new Redis acknowledgment layer.

Trait Implementations

impl<Conn: ConnectionLike + Send + Clone + 'static, Res, Encode> Acknowledge<Res, RedisContext, Ulid> for RedisAck<Conn, Encode>

where Encode: Codec<Res, Compact = Vec<u8>>,

type Future = Pin<Box<dyn Future<Output = Result<(), RedisError>> + Send>>

The future returned by the ack method

type Error = RedisError

The error type returned by the acknowledgment process

fn ack( &mut self, res: &Result<Res, BoxDynError>, parts: &Parts<RedisContext, Ulid>, ) -> Self::Future

Acknowledge the result of a task processing

impl<Conn, Encode> Clone for RedisAck<Conn, Encode>

where Conn: Clone, RedisConfig: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Conn: Debug, Encode: Debug> Debug for RedisAck<Conn, Encode>

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

Formats the value using the given formatter.