Struct TestNoStdRuntime 

pub struct TestNoStdRuntime<C, T, const NODE_COUNT: usize, const EDGE_COUNT: usize>
where
    C: PlatformClock + Sized,
    T: Telemetry + Sized,
{ /* private fields */ }

A tiny, no_std test runtime:

• round-robin over nodes
• uses a single occupancy array
• no heap, no threads, no timers

Implementations

impl<C, T, const NODE_COUNT: usize, const EDGE_COUNT: usize> TestNoStdRuntime<C, T, NODE_COUNT, EDGE_COUNT>

where C: PlatformClock + Sized, T: Telemetry + Sized,

pub const fn new() -> Self

Construct with a pessimistic initial occupancy; init() will overwrite it.

pub fn with_telemetry<F, R>(&mut self, f: F) -> Result<Option<R>, RuntimeError>

where F: FnOnce(&mut T) -> R,

Safely access telemetry by mutable reference, if it is present.

Returns:

• Ok(Some(r)) if telemetry is present and f ran.
• Ok(None) if telemetry is currently absent (e.g. not yet initialized).

This never panics and never moves telemetry out of the runtime.

Trait Implementations

impl<C, T, const NODE_COUNT: usize, const EDGE_COUNT: usize> Default for TestNoStdRuntime<C, T, NODE_COUNT, EDGE_COUNT>

where C: PlatformClock + Sized, T: Telemetry + Sized,

fn default() -> Self

Returns the “default value” for a type.

impl<Graph, C, T, const NODE_COUNT: usize, const EDGE_COUNT: usize> LimenRuntime<Graph, NODE_COUNT, EDGE_COUNT> for TestNoStdRuntime<C, T, NODE_COUNT, EDGE_COUNT>

where Graph: GraphApi<NODE_COUNT, EDGE_COUNT>, C: PlatformClock + Sized, T: Telemetry + Sized,

type Clock = C

Clock abstraction stored by the runtime. Use () if not needed.

type Telemetry = T

Telemetry collector stored by the runtime. Use () if not needed.

type Error = RuntimeError

Error type produced by the runtime. Use core::convert::Infallible if none.

type StopHandle = RuntimeStopHandle

External stop handle type. Clone + Send + Sync + 'static. Only available under std.

fn init( &mut self, graph: &mut Graph, clock: Self::Clock, telemetry: Self::Telemetry, ) -> Result<(), Self::Error>

Initialize internal state and adopt the provided clock & telemetry.

fn reset(&mut self, graph: &Graph) -> Result<(), Self::Error>

Reset internal runtime state (keep graph/node state unless your policy requires otherwise).

fn request_stop(&mut self)

Request a cooperative stop.

fn is_stopping(&self) -> bool

Return true iff a stop has been requested.

fn occupancies(&self) -> &[EdgeOccupancy; EDGE_COUNT]

Borrow the runtime’s persistent edge-occupancy buffer.

fn step(&mut self, graph: &mut Graph) -> Result<bool, Self::Error>

Execute one scheduler tick. Return Ok(true) if more work remains, Ok(false) to stop.

fn stop_handle(&self) -> Option<Self::StopHandle>

Return an external stop handle, if the runtime supports it. Clone before calling run() to enable stopping from another thread.

fn run(&mut self, graph: &mut Graph) -> Result<(), Self::Error>

Drive the runtime until step() returns false or a stop is requested.