Struct HandlerInput 

pub struct HandlerInput {
    pub run_id: RunId,
    pub attempt_id: AttemptId,
    pub payload: Vec<u8>,
    pub metadata: AttemptMetadata,
    pub cancellation_context: CancellationContext,
}

Execution context provided to the handler for each attempt.

This structure contains all information needed to execute an attempt including the run and attempt identifiers, the payload to execute, and constraints snapshot for timeout and retry behavior.

Cancellation contract

• If metadata.timeout_secs is Some, timeout enforcement may request cancellation while execution is in progress.
• Long-running handlers must poll CancellationToken::is_cancelled() at bounded intervals and exit promptly once cancellation is observed.
• Returning success after cancellation has been requested does not override timeout truth; timeout classification remains authoritative.

Fields

run_id: RunId

The unique identifier for the run instance.

attempt_id: AttemptId

The unique identifier for this specific attempt within the run.

payload: Vec<u8>

The opaque payload bytes to execute.

metadata: AttemptMetadata

The attempt-level execution metadata (timeout, retry policy, etc.).

cancellation_context: CancellationContext

The cancellation context for this execution. Handlers can check this to determine if execution should be terminated early.

Trait Implementations

impl Clone for HandlerInput

fn clone(&self) -> HandlerInput

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HandlerInput

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

Formats the value using the given formatter.