Struct RoutingTable 

pub struct RoutingTable { /* private fields */ }

Pre-computed routing table for O(1) DAG event dispatch.

Built from a finalized StreamingDag during topology construction (Ring 2). Provides cache-aligned O(1) lookups indexed by (node_id, port).

Performance Target

Route lookup: < 50ns (single cache-line read).

Implementations

impl RoutingTable

pub fn from_dag(dag: &StreamingDag) -> Self

Builds a routing table from a finalized StreamingDag.

Scans all nodes and their outgoing edges to populate routing entries. All targets for a node are collected into a single entry at port 0.

Arguments

• dag - A finalized StreamingDag topology

pub fn route(&self, source: NodeId, port: u8) -> &RoutingEntry

Looks up the routing entry for a (source, port) pair.

Arguments

• source - The source node ID
• port - The output port (typically 0)

Panics

Panics if the computed index is out of bounds.

pub fn node_targets(&self, source: NodeId) -> &RoutingEntry

Convenience method to get targets for a node’s primary output (port 0).

pub fn entry_count(&self) -> usize

Returns the total number of routing entries in the table.

pub fn max_node_id(&self) -> u32

Returns the maximum node ID covered by the table.

Trait Implementations

impl Debug for RoutingTable

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

Formats the value using the given formatter.