Trait apalis_core::layers::Ack

source · 
pub trait Ack<J> {
    type Acknowledger;
    type Error: Error;

    // Required method
    fn ack(
        &self,
        worker_id: &WorkerId,
        data: &Self::Acknowledger,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send;
}
Expand description

A trait for acknowledging successful processing

Required Associated Types§

source

type Acknowledger

The data to fetch from context to allow acknowledgement

source

type Error: Error

The error returned by the ack

Required Methods§

source

fn ack( &self, worker_id: &WorkerId, data: &Self::Acknowledger, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Acknowledges successful processing of the given request

Object Safety§

This trait is not object safe.

Implementors§