Struct ContextOrchestrator 

pub struct ContextOrchestrator { /* private fields */ }

Orchestrates multiple ContextRuntimes across OS threads.

Routes incoming events to the correct context based on event type and stream assignments.

Implementations

impl ContextOrchestrator

pub fn build( context_map: &ContextMap, program: &Program, output_tx: Sender<Event>, channel_capacity: usize, ) -> Result<Self, String>

Build the orchestrator from engine state.

For each declared context:

1. Creates a bounded mpsc channel
2. Creates an Engine with only the streams assigned to that context
3. Spawns an OS thread with optional CPU affinity
4. Inside the thread: creates a single-threaded Tokio runtime and runs the ContextRuntime event loop

pub fn build_with_checkpoint( context_map: &ContextMap, program: &Program, output_tx: Sender<Event>, channel_capacity: usize, checkpoint_config: Option<(CheckpointConfig, Arc<dyn StateStore>)>, recovery_checkpoint: Option<&Checkpoint>, ) -> Result<Self, String>

Build the orchestrator with optional checkpoint configuration and recovery state.

pub async fn process(&self, event: SharedEvent) -> Result<(), String>

Route an incoming event to the correct context (async, waits on backpressure).

pub fn try_process(&self, event: SharedEvent) -> Result<(), DispatchError>

Non-blocking dispatch — returns ChannelFull instead of waiting.

pub fn process_batch(&self, events: Vec<SharedEvent>) -> Vec<DispatchError>

Batch dispatch — non-blocking, returns errors for events that could not be sent.

pub fn router(&self) -> EventTypeRouter

Get a cloneable router handle for direct multi-producer dispatch.

pub fn shutdown(self)

Shut down all context threads.

Sends shutdown signal, drops senders, and waits for threads to finish.

pub fn trigger_checkpoint(&mut self)

Trigger a checkpoint across all contexts.

Sends a CheckpointBarrier to every context. Each context will snapshot its engine state and send a CheckpointAck back. Call try_complete_checkpoint() afterwards to drain acks and persist.

pub fn try_complete_checkpoint(&mut self) -> Result<bool, StoreError>

Try to complete a pending checkpoint by draining acknowledgments.

Returns true if a checkpoint was fully completed and persisted.

pub fn should_checkpoint(&self) -> bool

Check if a periodic checkpoint should be triggered (based on configured interval).

pub fn checkpoint_tick(&mut self) -> Result<bool, StoreError>

Run one checkpoint cycle: trigger if due, then try to complete.

Call this periodically from the main event loop (e.g., every second or on a timer).

pub fn context_names(&self) -> Vec<&str>

Get the names of all running contexts

pub const fn ingress_routing(&self) -> &FxHashMap<String, String>

Get the ingress routing table (for testing/debugging)

Trait Implementations

impl Debug for ContextOrchestrator

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

Formats the value using the given formatter.