Struct ContextRuntime 

pub struct ContextRuntime { /* private fields */ }

A self-contained single-threaded runtime for one context.

Owns its streams, processes events without locks. Receives events from its inbound channel and forwards cross-context events via outbound channels.

Implementations

impl ContextRuntime

pub const fn new( name: String, engine: Engine, output_tx: Sender<Event>, event_rx: Receiver<ContextMessage>, engine_output_rx: Receiver<Event>, all_context_txs: FxHashMap<String, Sender<ContextMessage>>, ingress_routing: FxHashMap<String, String>, shutdown_rx: Receiver<bool>, ) -> Self

Create a new context runtime

pub fn with_ack_sender(self, ack_tx: Sender<CheckpointAck>) -> Self

Set the checkpoint acknowledgment sender for coordinated checkpointing.

pub async fn run(&mut self)

Run the event loop. Blocks the current thread.

Receives events from the inbound channel, processes them through the engine, and forwards cross-context events as needed.

If the engine has session windows, a periodic sweep timer runs every gap duration to close stale sessions. This ensures sessions are emitted even when no new events arrive.

Trait Implementations

impl Debug for ContextRuntime

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

Formats the value using the given formatter.