Struct CompletionPayload 

#[non_exhaustive]
pub struct CompletionPayload {
    pub execution_id: ExecutionId,
    pub outcome: String,
    pub payload_bytes: Option<Vec<u8>>,
    pub produced_at_ms: TimestampMs,
    pub flow_id: Option<FlowId>,
}

One completion event delivered through the CompletionStream (RFC-012 §4.3). Also the payload type for issue #90’s subscription API. Stage 0 authorises the type; issue #90 fixes the wire shape.

flow_id was added in issue #90 so DAG-dependency routing (dispatch_dependency_resolution) has the partition-routable flow handle without reparsing the Lua-emitted JSON downstream. #[non_exhaustive] keeps future field additions additive; use CompletionPayload::new and CompletionPayload::with_flow_id for construction.

payload_bytes / produced_at_ms are authorised but not yet populated by the Valkey Lua emitters — consumers on the CompletionStream read execution_id + flow_id today and must tolerate payload_bytes = None / produced_at_ms = 0.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

execution_id: ExecutionId

outcome: String

payload_bytes: Option<Vec<u8>>

produced_at_ms: TimestampMs

flow_id: Option<FlowId>

Flow handle for partition routing. Added in issue #90 (#90); None for emitters that don’t yet surface it.

Implementations

impl CompletionPayload

pub fn new( execution_id: ExecutionId, outcome: impl Into<String>, payload_bytes: Option<Vec<u8>>, produced_at_ms: TimestampMs, ) -> Self

pub fn with_flow_id(self, flow_id: FlowId) -> Self

Attach a flow handle to the payload. Additive builder so adding flow_id didn’t require a breaking change to Self::new.

Trait Implementations

impl Clone for CompletionPayload

fn clone(&self) -> CompletionPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompletionPayload

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

Formats the value using the given formatter.

impl PartialEq for CompletionPayload

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for CompletionPayload

impl StructuralPartialEq for CompletionPayload