Struct AxEventRuntime 

pub struct AxEventRuntime {
    pub routes: Vec<AxEventRoute>,
    pub options: Value,
    pub descriptor: Value,
    pub store: AxInMemoryEventStore,
    /* private fields */
}

Fields

routes: Vec<AxEventRoute>

options: Value

descriptor: Value

store: AxInMemoryEventStore

Implementations

impl AxEventRuntime

pub fn new(routes: Vec<AxEventRoute>, options: Value) -> AxResult<Self>

pub fn set_clock(&mut self, clock: Arc<dyn AxEventClock>)

pub fn register_target(&mut self, target: AxEventTarget)

pub fn start(&mut self) -> AxResult<()>

pub fn start_source( &mut self, source: &mut dyn AxEventSource, identity_scope: &str, trust: &str, ) -> AxResult<Vec<AxEventPublishReceipt>>

pub fn plan( &self, event: &AxEventEnvelope, identity_scope: &str, trust: &str, ) -> AxResult<Vec<AxEventCommand>>

pub fn publish( &mut self, event: AxEventEnvelope, identity_scope: &str, trust: &str, ) -> AxResult<AxEventPublishReceipt>

pub fn next_due_at(&self) -> Option<i64>

pub fn run_due(&mut self) -> usize

pub fn cancel_run(&self, run_id: &str, reason: &str) -> bool

pub fn get_run(&self, run_id: &str) -> Option<&AxEventRun>

pub fn list_dead_letters(&self) -> Vec<AxEventDeadLetter>

pub fn redrive(&mut self, dead_id: &str) -> AxResult<()>

pub fn close(&mut self) -> AxResult<()>

pub fn normalize_mcp( namespace: &str, method: &str, params: Value, ) -> AxResult<Value>