Struct EmbeddedNodeRuntime 

pub struct EmbeddedNodeRuntime { /* private fields */ }

Implementations

impl EmbeddedNodeRuntime

pub fn new(config: RuntimeConfig) -> EmbeddedResult<Self>

Examples found in repository

examples/manual_tick_runtime.rs (line 8)

fn main() {
    let mut runtime = EmbeddedNodeRuntime::new(RuntimeConfig::default()).expect("runtime");
    let mut store = JournaledEmbeddedStore::new();
    let mut transport = BleShimTransport::new(BleShimConfig::default()).expect("transport");

    transport.set_link_state(LinkState::Up);
    runtime.tick(0, &mut transport, &mut store).expect("tick");
    runtime.queue_message([0x44; 16], b"hello from manual tick").expect("queue message");
    runtime.tick(1_000, &mut transport, &mut store).expect("tick");

    while let Some(frame) = transport.take_outbound_wire() {
        println!("outbound frame bytes={}", frame.len());
    }
}

pub fn bootstrap<S: EmbeddedStore>(&mut self, store: &S) -> EmbeddedResult<()>

pub fn tick<T: EmbeddedTransport, S: EmbeddedStore>( &mut self, now_ms: u64, transport: &mut T, store: &mut S, ) -> EmbeddedResult<()>

Examples found in repository

examples/manual_tick_runtime.rs (line 13)

fn main() {
    let mut runtime = EmbeddedNodeRuntime::new(RuntimeConfig::default()).expect("runtime");
    let mut store = JournaledEmbeddedStore::new();
    let mut transport = BleShimTransport::new(BleShimConfig::default()).expect("transport");

    transport.set_link_state(LinkState::Up);
    runtime.tick(0, &mut transport, &mut store).expect("tick");
    runtime.queue_message([0x44; 16], b"hello from manual tick").expect("queue message");
    runtime.tick(1_000, &mut transport, &mut store).expect("tick");

    while let Some(frame) = transport.take_outbound_wire() {
        println!("outbound frame bytes={}", frame.len());
    }
}

pub fn queue_message( &mut self, destination: [u8; 16], body: &[u8], ) -> EmbeddedResult<u32>

Examples found in repository

examples/manual_tick_runtime.rs (line 14)

fn main() {
    let mut runtime = EmbeddedNodeRuntime::new(RuntimeConfig::default()).expect("runtime");
    let mut store = JournaledEmbeddedStore::new();
    let mut transport = BleShimTransport::new(BleShimConfig::default()).expect("transport");

    transport.set_link_state(LinkState::Up);
    runtime.tick(0, &mut transport, &mut store).expect("tick");
    runtime.queue_message([0x44; 16], b"hello from manual tick").expect("queue message");
    runtime.tick(1_000, &mut transport, &mut store).expect("tick");

    while let Some(frame) = transport.take_outbound_wire() {
        println!("outbound frame bytes={}", frame.len());
    }
}

pub fn pending_outbound_len(&self) -> usize

pub fn config(&self) -> RuntimeConfig

pub fn lifecycle_state(&self) -> NodeLifecycleState

pub fn set_network_provisioned(&mut self, provisioned: bool)

pub fn set_ble_recovery_active(&mut self, active: bool)

pub fn stats(&self) -> RuntimeStats

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