Struct Router 

pub struct Router { /* private fields */ }

Generic message router for connector dispatch

Routes incoming messages to appropriate producers based on resource_id. Uses linear search which is efficient for <100 routes.

Performance

• O(M) complexity where M = number of routes
• May check multiple routes if same resource_id maps to multiple types
• Typical routing time: <1μs for <50 routes

Protocol Support

This router is protocol-agnostic. Each connector uses it with their own resource_id format:

• MQTT: topic (e.g., “sensors/temperature”)
• Kafka: topic or topic:partition (e.g., “events” or “events:0”)
• HTTP: path (e.g., “/api/v1/sensors”)
• DDS: topic_name (e.g., “TelemetryData”)
• Shmem: segment_name (e.g., “temperature_buffer”)

Implementations

impl Router

pub fn new(routes: Vec<Route>) -> Self

Create a new router with the given routes

pub async fn route( &self, resource_id: &str, payload: &[u8], ) -> Result<(), String>

Route a message to appropriate producer(s)

Arguments

• resource_id - Resource identifier (topic, path, segment name, etc.)
• payload - Raw message payload bytes

Returns

• Ok(()) - At least one route successfully processed the message
• Err(_) - All routes failed (or no routes found)

Behavior

• Checks all routes that match the resource_id (may be multiple)
• Logs warnings on deserialization failures but continues
• Logs debug message if no routes found for resource_id

pub fn resource_ids(&self) -> Vec<Arc<str>>

Get list of all resource IDs registered in this router

Useful for subscribing at the protocol level (e.g., MQTT SUBSCRIBE). Returns unique resource IDs (deduplicated even if multiple routes per resource).

pub fn route_count(&self) -> usize

Get the number of routes in this router