Struct MeshRouter 

pub struct MeshRouter<A: Aggregator = NoOpAggregator> { /* private fields */ }

Unified mesh router combining routing, aggregation, and transport

MeshRouter provides a high-level API for routing data through the mesh hierarchy while handling deduplication and aggregation automatically.

The type parameter A determines which aggregation strategy is used. Use NoOpAggregator (the default) when aggregation is not needed.

Implementations

impl MeshRouter<NoOpAggregator>

pub fn new(config: MeshRouterConfig) -> Self

Create a new mesh router with no aggregation

pub fn with_node_id(node_id: impl Into<String>) -> Self

Create with default configuration and node ID (no aggregation)

impl<A: Aggregator> MeshRouter<A>

pub fn with_aggregator(config: MeshRouterConfig, aggregator: A) -> Self

Create a new mesh router with a specific aggregator

pub fn route(&self, packet: &DataPacket, state: &TopologyState) -> RouteResult

Route an incoming packet and determine what to do with it

This is the main entry point for processing received packets. It handles deduplication, routing decisions, and aggregation checks.

Arguments

• packet - The incoming data packet
• state - Current topology state

Returns

RouteResult containing the routing decision and forwarding targets

pub fn add_for_aggregation( &self, packet: DataPacket, squad_id: &str, ) -> Option<DataPacket>

Add a telemetry packet to the aggregation buffer

If aggregation threshold is reached, returns aggregated packet. Otherwise returns None.

pub fn pending_aggregation_count(&self) -> usize

Get the number of packets pending aggregation

pub fn flush_aggregation(&self, squad_id: &str) -> Option<DataPacket>

Force aggregation of pending packets (even if below threshold)

pub fn router(&self) -> &SelectiveRouter

Get the underlying router for advanced operations

pub fn aggregator(&self) -> &A

Get the underlying aggregator for advanced operations

pub fn node_id(&self) -> &str

Get the node ID this router is configured for

pub fn dedup_cache_size(&self) -> usize

Get deduplication cache size

pub fn clear_dedup_cache(&self)

Clear deduplication cache