Struct KernelRuntime 

pub struct KernelRuntime<S> { /* private fields */ }

Implementations

impl<S> KernelRuntime<S>

where S: MemoryStore,

pub fn load(store: S) -> Result<Self, RuntimeError>

Examples found in repository

examples/runtime_persistence.rs (line 21)

fn run() -> Result<(), Box<dyn std::error::Error>> {
    let path = temp_state_path("runtime");
    let mut runtime = KernelRuntime::load(JsonFileStore::new(&path))?;

    let receipt = runtime.write_with_receipt("apps.demo.home.count", 3_u64)?;
    let json = runtime_receipt_to_json(&receipt);

    assert_eq!(json["events"][0]["path"][0], "apps");
    assert_eq!(json["events"][0]["path"][2], "home");
    assert_eq!(json["events"][0]["value"], 3.0);

    let restored = KernelRuntime::load(JsonFileStore::new(&path))?;
    assert_eq!(
        restored.read("apps.demo.home.count"),
        Some(&Value::from(3_u64))
    );
    assert!(restored.events().is_empty());

    println!("{json}");
    let _ = fs::remove_file(path);
    Ok(())
}

pub fn new(kernel: Kernel, store: S) -> Self

pub fn kernel(&self) -> &Kernel

pub fn kernel_mut(&mut self) -> &mut Kernel

pub fn store(&self) -> &S

pub fn save(&self) -> Result<(), RuntimeError>

pub fn read(&self, path: impl IntoPath) -> Option<&Value>

Examples found in repository

examples/runtime_persistence.rs (line 32)

fn run() -> Result<(), Box<dyn std::error::Error>> {
    let path = temp_state_path("runtime");
    let mut runtime = KernelRuntime::load(JsonFileStore::new(&path))?;

    let receipt = runtime.write_with_receipt("apps.demo.home.count", 3_u64)?;
    let json = runtime_receipt_to_json(&receipt);

    assert_eq!(json["events"][0]["path"][0], "apps");
    assert_eq!(json["events"][0]["path"][2], "home");
    assert_eq!(json["events"][0]["value"], 3.0);

    let restored = KernelRuntime::load(JsonFileStore::new(&path))?;
    assert_eq!(
        restored.read("apps.demo.home.count"),
        Some(&Value::from(3_u64))
    );
    assert!(restored.events().is_empty());

    println!("{json}");
    let _ = fs::remove_file(path);
    Ok(())
}

pub fn read_fresh(&mut self, path: impl IntoPath) -> Option<Value>

pub fn write( &mut self, path: impl IntoPath, value: impl Into<Value>, ) -> Result<Memory, RuntimeError>

pub fn write_with_receipt( &mut self, path: impl IntoPath, value: impl Into<Value>, ) -> Result<RuntimeReceipt<Memory>, RuntimeError>

Examples found in repository

examples/runtime_persistence.rs (line 23)

fn run() -> Result<(), Box<dyn std::error::Error>> {
    let path = temp_state_path("runtime");
    let mut runtime = KernelRuntime::load(JsonFileStore::new(&path))?;

    let receipt = runtime.write_with_receipt("apps.demo.home.count", 3_u64)?;
    let json = runtime_receipt_to_json(&receipt);

    assert_eq!(json["events"][0]["path"][0], "apps");
    assert_eq!(json["events"][0]["path"][2], "home");
    assert_eq!(json["events"][0]["value"], 3.0);

    let restored = KernelRuntime::load(JsonFileStore::new(&path))?;
    assert_eq!(
        restored.read("apps.demo.home.count"),
        Some(&Value::from(3_u64))
    );
    assert!(restored.events().is_empty());

    println!("{json}");
    let _ = fs::remove_file(path);
    Ok(())
}

pub fn execute( &mut self, target: impl AsRef<str>, body: Option<ExecuteValue>, ) -> Result<ExecuteValue, RuntimeError>

pub fn execute_with_receipt( &mut self, target: impl AsRef<str>, body: Option<ExecuteValue>, ) -> Result<RuntimeReceipt<ExecuteValue>, RuntimeError>

pub fn events(&self) -> &[KernelEvent]

Examples found in repository

examples/runtime_persistence.rs (line 35)

fn run() -> Result<(), Box<dyn std::error::Error>> {
    let path = temp_state_path("runtime");
    let mut runtime = KernelRuntime::load(JsonFileStore::new(&path))?;

    let receipt = runtime.write_with_receipt("apps.demo.home.count", 3_u64)?;
    let json = runtime_receipt_to_json(&receipt);

    assert_eq!(json["events"][0]["path"][0], "apps");
    assert_eq!(json["events"][0]["path"][2], "home");
    assert_eq!(json["events"][0]["value"], 3.0);

    let restored = KernelRuntime::load(JsonFileStore::new(&path))?;
    assert_eq!(
        restored.read("apps.demo.home.count"),
        Some(&Value::from(3_u64))
    );
    assert!(restored.events().is_empty());

    println!("{json}");
    let _ = fs::remove_file(path);
    Ok(())
}

pub fn events_matching( &self, path: impl IntoPath, ) -> Result<Vec<KernelEvent>, RuntimeError>

pub fn drain_events(&mut self) -> Vec<KernelEvent>

pub fn drain_events_matching( &mut self, path: impl IntoPath, ) -> Result<Vec<KernelEvent>, RuntimeError>

Trait Implementations

impl<S: Debug> Debug for KernelRuntime<S>

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

Formats the value using the given formatter.