Struct CompletionEvent 

#[non_exhaustive]
pub struct CompletionEvent {
    pub cursor: StreamCursor,
    pub execution_id: ExecutionId,
    pub outcome: CompletionOutcome,
    pub at: TimestampMs,
}

Per-event payload of subscribe_completion.

Completion events are terminal state transitions surfaced to downstream DAG consumers. Postgres carries a durable event-id cursor; Valkey Stage B rides pubsub + always yields StreamCursor::empty (no durable replay).

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.

cursor: StreamCursor

execution_id: ExecutionId

outcome: CompletionOutcome

at: TimestampMs

Implementations

impl CompletionEvent

pub fn new( cursor: StreamCursor, execution_id: ExecutionId, outcome: CompletionOutcome, at: TimestampMs, ) -> Self

Construct a CompletionEvent. Backend adapters go through this constructor instead of struct-literal syntax so future additive fields land as builder methods without breaking call sites.

Trait Implementations

impl Clone for CompletionEvent

fn clone(&self) -> CompletionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompletionEvent

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

Formats the value using the given formatter.