Struct Engine 

pub struct Engine {
    pub defs: BTreeMap<(String, i64), Machine>,
    pub latest: BTreeMap<String, i64>,
    pub instances: BTreeMap<InstanceId, Instance>,
    pub clock: u64,
    pub mode: Mode,
    pub observer: Option<Box<dyn FnMut(&StepRecord) + Send>>,
    /* private fields */
}

Fields

defs: BTreeMap<(String, i64), Machine>

latest: BTreeMap<String, i64>

instances: BTreeMap<InstanceId, Instance>

clock: u64

mode: Mode

observer: Option<Box<dyn FnMut(&StepRecord) + Send>>

Implementations

impl Engine

pub fn new() -> Self

pub fn set_observer<F: FnMut(&StepRecord) + Send + 'static>(&mut self, f: F)

pub fn register(&mut self, m: Machine)

pub fn def( &self, id: &str, version: Option<i64>, ) -> Result<&Machine, EngineError>

pub fn create_root( &mut self, id: &str, def_id: &str, version: Option<i64>, external: &BTreeMap<String, Value>, ) -> Result<(), EngineError>

pub fn instance(&self, id: &str) -> Result<&Instance, EngineError>

pub fn validate_event( &self, inst_id: &str, etype: &str, payload: &Value, ) -> Result<(), String>

pub fn inject( &mut self, inst_id: &str, etype: &str, payload: Value, ) -> Result<bool, EngineError>

pub fn send( &mut self, inst_id: &str, etype: &str, payload: Value, ) -> Result<RunResult, EngineError>

pub fn advance(&mut self, duration_ms: u64) -> Result<RunResult, EngineError>

pub fn step( &mut self, inst_id: &str, n: usize, ) -> Result<Vec<StepRecord>, EngineError>

pub fn env_change( &mut self, inst_id: &str, changed: BTreeMap<String, Value>, ) -> Result<RunResult, EngineError>

pub fn set_mode(&mut self, mode: Mode)

pub fn get_mode(&self) -> Mode

pub fn migrate_quiescent(&mut self) -> Result<(), EngineError>

Migrate eligible quiescent instances to a newer registered version (SPEC §10.2).

pub fn state_view(&self, inst_id: &str) -> Result<StateView, EngineError>

pub fn list_view(&self) -> Vec<ListView>

pub fn inspect_view(&self, inst_id: &str) -> Result<InspectView, EngineError>

pub fn enabled_events(&self, inst_id: &str) -> Result<Vec<String>, EngineError>

enabled_events(instance) — sorted declared event types the current active configuration can handle (SPEC §14).

pub fn snapshot(&self, inst_id: &str) -> Result<Snapshot, EngineError>

pub fn restore(&mut self, snap: Snapshot) -> Result<(), EngineError>

Trait Implementations

impl Default for Engine

fn default() -> Self

Returns the “default value” for a type.