Enum TaskEvent 

#[non_exhaustive]
pub enum TaskEvent<Res> {
    Complete(TaskResult<Res>),
    Lock {
        task_id: TaskId,
    },
    Release {
        task_id: TaskId,
    },
    Cancel {
        task_id: TaskId,
    },
}

Available on crate feature sleep only.

A message representing a state transition or event for a task within the task processing system.

Res is the task’s associated output/payload type, and Id is the underlying identifier type used to uniquely reference a task.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Complete(TaskResult<Res>)

Signals that a task has finished processing, carrying its result.

This is sent once a worker has finished executing a task, regardless of whether it succeeded or failed — the outcome itself is encoded in TaskResult.

Lock

Requests that a lock has been acquired on the given task, preventing other workers from picking it up concurrently.

Fields

task_id: TaskId

The identifier of the task being locked.

Release

Releases a previously acquired lock on the given task, making it available for other workers to claim.

This is typically sent after a task completes, fails, or its lock needs to be freed without marking the task as complete (e.g. on worker shutdown).

Fields

task_id: TaskId

The identifier of the task whose lock is being released.

Cancel

Requests that the given task be cancelled.

This may be sent before a task has started, or while it is in progress, depending on what the consuming system supports.

Fields

task_id: TaskId

The identifier of the task being cancelled.

Trait Implementations

impl<Res: Clone> Clone for TaskEvent<Res>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Res: Debug> Debug for TaskEvent<Res>

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

Formats the value using the given formatter.

impl<'de, Res> Deserialize<'de> for TaskEvent<Res>

where Res: Deserialize<'de>,

Available on crate feature serde only.

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Res> Serialize for TaskEvent<Res>

where Res: Serialize,

Available on crate feature serde only.

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.