Struct StepContext 

pub struct StepContext<'graph, 'telemetry, 'clock, const IN: usize, const OUT: usize, InP, OutP, InQ, OutQ, InM, OutM, C, T>
where
    InP: Payload,
    OutP: Payload,
    C: PlatformClock + Sized,
    T: Telemetry + Sized,
{ /* private fields */ }

A context provided to nodes during step, abstracting queues, managers, and services.

The context is generic over input/output payload, queue, memory manager, clock, and telemetry types to avoid trait objects.

Implementations

impl<'graph, 'telemetry, 'clock, const IN: usize, const OUT: usize, InP, OutP, InQ, OutQ, InM, OutM, C, T> StepContext<'graph, 'telemetry, 'clock, IN, OUT, InP, OutP, InQ, OutQ, InM, OutM, C, T>

where InP: Payload, OutP: Payload, C: PlatformClock + Sized, T: Telemetry + Sized,

pub fn new( inputs: [&'graph mut InQ; IN], outputs: [&'graph mut OutQ; OUT], in_managers: [&'graph mut InM; IN], out_managers: [&'graph mut OutM; OUT], in_policies: [EdgePolicy; IN], out_policies: [EdgePolicy; OUT], node_id: u32, in_edge_ids: [u32; IN], out_edge_ids: [u32; OUT], clock: &'clock C, telemetry: &'telemetry mut T, ) -> Self

Create a new step context from queues, managers, policies, and services.

impl<'graph, 'telemetry, 'clock, const IN: usize, const OUT: usize, InP, OutP, InQ, OutQ, InM, OutM, C, T> StepContext<'graph, 'telemetry, 'clock, IN, OUT, InP, OutP, InQ, OutQ, InM, OutM, C, T>

where InP: Payload, OutP: Payload, InQ: Edge, OutQ: Edge, InM: MemoryManager<InP>, OutM: MemoryManager<OutP>, C: PlatformClock + Sized, T: Telemetry + Sized,

pub fn in_peek_header( &self, i: usize, ) -> Result<InM::HeaderGuard<'_>, QueueError>

Peek the front message header on the specified input port (non-consuming).

Returns a guard that dereferences to MessageHeader. The guard must be dropped before any mutable operation on the same manager slot.

pub fn pop_and_process<F>( &mut self, port: usize, f: F, ) -> Result<StepResult, NodeError>

where F: FnOnce(&Message<InP>) -> Result<ProcessResult<OutP>, NodeError>,

Pop one message from input port, call f with a shared reference, then push any output and free the manager slot.

pub fn pop_batch_and_process<F>( &mut self, port: usize, nmax: usize, node_policy: &NodePolicy, f: F, ) -> Result<StepResult, NodeError>

where F: FnMut(&Message<InP>) -> Result<ProcessResult<OutP>, NodeError>,

Pop a batch from input port. Set batch flags on popped tokens. Call f for each message in the batch, pushing any outputs internally. After processing, free all consumed tokens.

pub fn in_occupancy(&mut self, i: usize) -> EdgeOccupancy

Return a snapshot of occupancy of the specified input queue.

pub fn in_policy(&mut self, i: usize) -> EdgePolicy

Return the policy of the specified input queue.

pub fn out_try_push(&mut self, o: usize, m: Message<OutP>) -> EnqueueResult

Push a message to the specified output port.

Stores the message in the output memory manager, then pushes the resulting token to the edge. Handles eviction: if DropOldest evicts a token, the evicted token is freed from the manager.

pub fn push_output( &mut self, port: usize, msg: Message<OutP>, ) -> Result<StepResult, NodeError>

Push an output message to the specified output port and map the result to a StepResult.

Stores the message in the output memory manager, performs pre-eviction (popping and freeing all slots the admission policy requires), then pushes the token to the edge. Residual eviction from a concurrent race is also freed. This guarantees zero manager slot leaks across all edge tiers and admission policies.

pub fn out_occupancy(&mut self, o: usize) -> EdgeOccupancy

Return a snapshot of occupancy of the specified output queue.

pub fn out_policy(&mut self, i: usize) -> EdgePolicy

Return the policy of the specified output queue.

pub fn clock(&self) -> &C

Access the platform clock used for timing and conversions.

pub fn telemetry_mut(&mut self) -> &mut T

Borrow the telemetry sink to emit custom counters/gauges/histograms.

pub fn now_ticks(&self) -> Ticks

Current monotonic tick value from the platform clock.

pub fn now_nanos(&self) -> u64

Current time in nanoseconds per the clock’s tick-to-ns mapping.

pub fn ticks_to_nanos(&self, t: Ticks) -> u64

Convert clock ticks to nanoseconds using the clock’s scale.

pub fn nanos_to_ticks(&self, ns: u64) -> Ticks

Convert nanoseconds to clock ticks using the clock’s scale.

pub fn input_edge_has_batch(&mut self, port: usize, policy: &NodePolicy) -> bool

Return true if the input edge port can produce a batch under policy.

Uses the input manager’s HeaderStore to peek creation ticks for span validation when both fixed_n and max_delta_t are set.