Struct TaskPersistLayer 

pub struct TaskPersistLayer<C, Compact> { /* private fields */ }

Available on crate feature sleep only.

A middleware layer that persists task lifecycle events.

TaskPersistLayer sends task events to a persistence channel and can be configured to persist task results and lock tasks while they are being processed.

Type Parameters

• C - The codec used to encode task data.
• Compact - The compact representation used for persisted task events.

Implementations

impl<Compact, C> TaskPersistLayer<C, Compact>

pub fn persist_results(self, persist_results: bool) -> Self

Configures whether task results should be persisted.

By default, task results are not persisted.

pub fn lock_tasks(self, lock_tasks: bool) -> Self

Configures whether tasks should be locked while being processed.

By default, tasks are not locked.

Trait Implementations

impl<C: Clone, Compact: Clone> Clone for TaskPersistLayer<C, Compact>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug, Compact: Debug> Debug for TaskPersistLayer<C, Compact>

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

Formats the value using the given formatter.

impl<S, Compact, C> Layer<S> for TaskPersistLayer<C, Compact>

where C: Clone,

type Service = TaskPersistService<S, Compact, C>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.