Struct EngineLoopEventSink 

pub struct EngineLoopEventSink { /* private fields */ }

Recorder-backed sink used by the engine’s cadence service.

Implementations

impl EngineLoopEventSink

pub fn new( registry: Arc<Registry>, store: Arc<dyn EventStore>, visibility_store: Arc<dyn VisibilityStore>, ) -> Self

Builds the sink over the engine’s registry and stores.

Trait Implementations

impl LoopEventSink for EngineLoopEventSink

fn record_cadence_fired<'life0, 'life1, 'async_trait>( &'life0 self, loop_id: &'life1 WorkflowId, window_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<RecordOutcome, WorkloopError>> + Send + 'async_trait>>

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

Record CadenceFired { window_seq } in the loop’s history.

fn record_invariant_unconfirmed<'life0, 'life1, 'async_trait>( &'life0 self, loop_id: &'life1 WorkflowId, alarm: InvariantAlarm, ) -> Pin<Box<dyn Future<Output = Result<(), WorkloopError>> + Send + 'async_trait>>

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

Record InvariantUnconfirmed (the one alarm path) in the loop’s history. UNLIKE cadence fires, this append is honoured even after the run’s terminal: the alarm that reports a loop’s death must not be silenced by the very death it reports (R5.3’s premise). The event is status-invisible, so the terminal projection is untouched.