Trait Task

pub trait Task:
    Serialize
    + DeserializeOwned
    + 'static {
    const TASK_KEY: &'static str;
    const TASK_QUEUE: &'static str;
    const RETRY_POLICY: RetryPolicy = _;
    const DELAY_SECONDS: u32 = 3u32;

    // Required method
    fn run(self) -> TaskFuture;

    // Provided methods
    fn validate(&self, kind: &TaskKind) -> Result<(), String> { ... }
    fn new_meta(&self, kind: TaskKind) -> TaskMeta { ... }
}

Required Associated Constants

const TASK_KEY: &'static str

A unique identifier for this task.

This name must be unique and is used to identify the task.

const TASK_QUEUE: &'static str

The default queue associated with this task.

This can be overridden at the individual task level. If a non-existent queue is specified, the task will not be processed.

Provided Associated Constants

const RETRY_POLICY: RetryPolicy = _

The retry policy for this task.

Defines the strategy and maximum retry attempts in case of failure. Default is exponential backoff with a base of 2 and a maximum of 5 retries.

const DELAY_SECONDS: u32 = 3u32

Delay before executing a Once task, in seconds.

Specifies the delay before starting a Once task after it is scheduled.

Required Methods

fn run(self) -> TaskFuture

Executes the task with the given parameters.

Contains the logic required to perform the task. Takes parameters of type Self::Params that can be used during execution.

Provided Methods

fn validate(&self, kind: &TaskKind) -> Result<(), String>

Validates the parameters based on the task type.

Checks that the necessary fields for the specific TaskKind are provided.

fn new_meta(&self, kind: TaskKind) -> TaskMeta

Creates a new metadata entry for the task.

This method generates a TaskMetaEntity instance based on the task’s properties. It validates required fields and panics if validation fails.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors