Struct TaskSpecAdapter 

pub struct TaskSpecAdapter<S>(/* private fields */);

Zero-sized adapter from typed task specs to object-safe task specs.

Implementations

impl<S> TaskSpecAdapter<S>

pub const fn new() -> Self

Creates a task spec adapter.

Trait Implementations

impl<S> Default for TaskSpecAdapter<S>

fn default() -> Self

Returns the “default value” for a type.

impl<S, State, Task, Config, Context, Kind, Lane, PayloadEnvelope, ResultEnvelope, Error> ErasedBackgroundTaskSpec<State, Task, Config, Context, Kind, Lane, PayloadEnvelope, ResultEnvelope, Error> for TaskSpecAdapter<S>

where S: BackgroundTaskSpec<State, Task, Config, Context, Error, Kind = Kind, Lane = Lane, PayloadEnvelope = PayloadEnvelope, ResultEnvelope = ResultEnvelope> + Sync, Task: TaskRecord<Kind>, Kind: Copy + Eq + Debug + Display + Send + Sync + 'static, Lane: Copy + Eq + Debug + Send + Sync + 'static,

fn step_specs(&self) -> &'static [TaskStepSpec]

Initial step specs for this task kind.

fn lane(&self) -> Lane

Dispatch lane used by this task kind.

fn max_attempts(&self, runtime_config: &Config) -> i32

Maximum attempts for new tasks of this kind.

fn decode_payload(&self, task: &Task) -> Result<PayloadEnvelope>

Decodes the product task payload envelope.

fn decode_result(&self, task: &Task) -> Result<Option<ResultEnvelope>>

Decodes the product task result envelope.

fn retry_class(&self, error: &Error) -> TaskRetryClass

Classifies a task failure for retry behavior.

fn process<'a>( &self, state: &'a State, task: &'a Task, context: Context, ) -> TaskProcessFuture<'a, Error>

Processes the task.