Struct DispatchRequest 

pub struct DispatchRequest {
    pub activity_type: String,
    pub workflow_id: WorkflowId,
    pub ordinal: u64,
    pub run_id: Option<RunId>,
    pub completion_token: String,
    pub idempotency_key: String,
    pub input: Vec<u8>,
    pub attempt: u32,
    pub labels: BTreeMap<String, String>,
    pub heartbeat_window_ms: u64,
}

Wire request carrying one scheduled activity to a liminal worker.

Mirrors the dispatch half of the gRPC ActivityTask: the fields the worker needs to execute the activity and to correlate its result back to the exact execution (workflow_id, ordinal, run_id). run_id rides end-to-end so the existing continue-as-new run gates hold over the liminal wire (the design doc §3.3 requirement that RunId stays on the wire).

Fields

activity_type: String

Activity type the worker must execute.

workflow_id: WorkflowId

Workflow that scheduled this fan-out activity. Carried in its serde form so no fragile id parsing happens on the wire.

ordinal: u64

Pinned ordinal of this activity within the workflow’s fan-out range.

run_id: Option<RunId>

Run that dispatched this ordinal, when known (continue-as-new safety).

completion_token: String

Opaque execution-generation proof echoed verbatim by the worker.

idempotency_key: String

Stable external-effect key for this run and action site.

input: Vec<u8>

Opaque activity input bytes (JSON-tagged on the aion side), in the one payload-bytes wire shape (aion_core::payload_bytes): a base64 string or an array of byte integers decode; the encoder is the codec’s.

attempt: u32

One-based delivery attempt, mirroring the gRPC ActivityTask.attempt. The engine-seam bridge threads the real attempt so a retry executes with attempt-aware handler semantics identical to the gRPC transport; the outbox path stamps the row’s stored zero-based attempt as one-based. Serde-defaulted to 1 so a frame from a pre-attempt server (or an old recorded frame) still decodes as a first delivery.

labels: BTreeMap<String, String>

Engine-provided routing/metadata labels, mirroring the gRPC ActivityTask.labels. Empty (the serde default) on the outbox path, which has no label source.

heartbeat_window_ms: u64

The server’s heartbeat window in milliseconds when this dispatch is tracked by the server’s per-task liveness tracker (the engine-seam bridge path), or 0 when it is not (the outbox path, whose liveness backstop is its own retry loop). A non-zero window tells the worker to pump automatic liveness beats at a quarter-window cadence so the server’s heartbeat sweeper never expires a healthy long-running activity — the exact liminal mirror of the gRPC worker’s automatic liveness pump.

Trait Implementations

impl Clone for DispatchRequest

fn clone(&self) -> DispatchRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DispatchRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DispatchRequest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for DispatchRequest

impl PartialEq for DispatchRequest

fn eq(&self, other: &DispatchRequest) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl SchemaValidate for DispatchRequest

fn schema_metadata() -> SchemaMetadata

Returns this message type’s schema metadata.

impl Serialize for DispatchRequest

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DispatchRequest