Struct DispatchEngine 

pub struct DispatchEngine { /* private fields */ }

Dispatch engine: accepts FiredEvents from the supervisor and orchestrates context capture, audit recording, and trigger invocation.

Typical P2 runtime usage:

loop {
    let (fired, health) = supervisor.poll();
    engine.process(fired);
}

Implementations

impl DispatchEngine

pub fn new( context_window: usize, trigger_handler: Box<dyn TriggerHandler>, recorder: Box<dyn DispatchRecorder>, ) -> Self

pub fn process(&mut self, fired: Vec<FiredEvent>)

Process a batch of FiredEvents from one supervisor poll cycle.

For each event:

1. Snapshot the context ring and insert the event.
2. Record a Dispatched audit event (idempotency marker, before firing).
3. Invoke the trigger handler.
4. On failure, record a Failed audit event with the structured cause.