Struct RunCompleted 

pub struct RunCompleted { /* private fields */ }

One CloudEvents message per completed run.

The default an embedder gets for free, and the shape most services want: a run finished, here is its identity, its outcome and its chain head. Every other record projects to nothing, so the cursor sweeps past a run’s whole history and delivers once.

Why the outcome is all that travels

Not the answer. A run’s output is domain data with a label on it, and a projection that shipped it by default would send whatever the run happened to hold to whatever the operator happened to configure, with no ceiling anybody declared — an egress decision made by a default. A deployment that wants the payload writes its own Projection and makes that decision explicitly.

id is the run id and source is the deployment, which is the pair CloudEvents defines uniqueness by — so a duplicate delivery, which at-least-once guarantees will happen, is detectable as a duplicate rather than as a second event. The same id rides in the delivery’s HEADER_ID header, so a receiver can drop a repeat before parsing the body and cannot end up with two answers to which message is this.

subject is the run, which is what the event is about within this producer. A receiver filtering by run would otherwise have to open data to find out.

There is no time, and that is honest

CloudEvents makes it optional, and this crate has nothing true to put in it. A journal record carries no wall clock: time in a run comes from journaled clock.now effects, precisely so that a replay sees the instant the run saw. Reading the ambient clock at delivery would stamp an event with when the outbox happened to sweep — which for a receiver that was down for two hours is a lie about when the run finished, told with more precision than the truth. A deployment that needs the instant projects it from its own records.

Implementations

impl RunCompleted

pub fn new(source: impl Into<String>) -> Self

source is the CloudEvents source URI for this deployment.

pub fn for_tenant(self, tenant: impl Into<String>) -> Self

Stamp every event with a tenantid extension.

For a multi-tenant plane posting to one operator bus: without it, two tenants’ completions are indistinguishable envelopes, and the inbound side of this crate already binds tenants on exactly this extension.

pub fn event_type(self, event_type: impl Into<String>) -> Self

Override the CloudEvents type.

Trait Implementations

impl Clone for RunCompleted

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunCompleted

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

Formats the value using the given formatter.

impl Projection for RunCompleted

fn messages<'life0, 'life1, 'async_trait>( &'life0 self, record: &'life1 Record, ) -> Pin<Box<dyn Future<Output = Result<Vec<PushMessage>, StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The messages this record becomes, in delivery order.

fn namespace(&self) -> PushNamespace

Which id namespace this worker serves.

fn terminal(&self, record: &Record) -> bool

Whether this record ends the stream for its run.