Struct Route 

pub struct Route {
    pub resource_id: Arc<str>,
    pub ingest: IngestFn,
}

A single routing entry

Maps one (resource_id, type) pair to a fused ingest callback. Multiple routes can exist for the same resource_id (different types).

Resource ID Examples

• MQTT: “sensors/temperature” (topic)
• Kafka: “events:0” (topic:partition)
• HTTP: “/api/v1/sensors” (path)
• DDS: “TelemetryData” (topic name)
• Shmem: “temperature_buffer” (segment name)

Fields

resource_id: Arc<str>

Resource identifier to match (reference-counted for proper memory management)

Examples: MQTT topic, Kafka topic, HTTP path, DDS topic, shmem segment

Uses Arc<str> instead of &'static str to avoid memory leaks from Box::leak(). This adds ~8 bytes overhead per route (Arc control block) but enables proper cleanup.

ingest: IngestFn

Fused ingest callback: deserialize + produce in one typed closure built at registration time (no Box<dyn Any> per message).