Struct RedisPersistence 

pub struct RedisPersistence<Conn = ConnectionManager> { /* private fields */ }

The default persistence implementation

Trait Implementations

impl<C: Clone> Clone for RedisPersistence<C>

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> Debug for RedisPersistence<Conn>

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

Formats the value using the given formatter.

impl<C> Persistence for RedisPersistence<C>

where C: ConnectionLike + Send + Sync + 'static + Clone,

type Compact = Vec<u8>

The compact type the upstream backend will use

type Error = Error

Error returned by persistence operations.

type Response = Value

The response type to be stored in the db

async fn register(&mut self, worker: &WorkerContext) -> Result<(), Error>

Registers the worker with the persistence backend.

async fn heartbeat(&mut self, worker: &WorkerContext) -> Result<(), Error>

Records a heartbeat for the worker.

async fn fetch_next( &mut self, worker: &WorkerContext, ) -> Result<Vec<RedisTask>, Error>

Fetches the next batch of tasks available for processing.

async fn handle_events( &mut self, messages: Vec<TaskEvent<Self::Response>>, worker: &WorkerContext, ) -> Result<(), Error>

Handles task lifecycle events produced by the worker.

async fn reenqueue_abandoned( &mut self, tasks: Vec<RedisTask>, worker: &WorkerContext, ) -> Result<u64, Error>

Re-enqueues tasks that were abandoned by a worker.

async fn push_tasks( &mut self, tasks: Vec<Task<Self::Compact>>, ) -> Result<(), Self::Error>

Handle tasks being pushed