Struct RouterBuilder 

pub struct RouterBuilder { /* private fields */ }

Builder for constructing routers

Provides a fluent API for adding routes before creating the router.

Example

use aimdb_core::router::RouterBuilder;

let router = RouterBuilder::new()
    .add_route(
        "sensors/temperature",
        producer_temp.clone(),
        Arc::new(|bytes| {
            serde_json::from_slice::<Temperature>(bytes)
                .map(|t| Box::new(t) as Box<dyn Any + Send>)
                .map_err(|e| e.to_string())
        })
    )
    .add_route(
        "sensors/humidity",
        producer_humidity.clone(),
        Arc::new(|bytes| {
            serde_json::from_slice::<Humidity>(bytes)
                .map(|h| Box::new(h) as Box<dyn Any + Send>)
                .map_err(|e| e.to_string())
        })
    )
    .build();

Implementations

impl RouterBuilder

pub fn new() -> Self

Create a new router builder

pub fn from_routes( routes: Vec<(String, Box<dyn ProducerTrait>, DeserializerFn)>, ) -> Self

Create a router builder from a collection of routes

This is a convenience method for automatic router construction from AimDb::collect_inbound_routes(). The resource_ids are converted to Arc for proper memory management.

Arguments

• routes - Vector of (resource_id, producer, deserializer) tuples

Example

let routes = db.collect_inbound_routes("mqtt");
let router = RouterBuilder::from_routes(routes).build();
connector.set_router(router).await?;

pub fn add_route( self, resource_id: Arc<str>, producer: Box<dyn ProducerTrait>, deserializer: DeserializerFn, ) -> Self

Add a route to the router

Arguments

• resource_id - Resource identifier to match (as Arc)
• producer - Producer that implements ProducerTrait
• deserializer - Function to deserialize bytes to the target type

Resource ID Memory Management

The resource_id is stored as Arc for proper reference counting and cleanup. You can create an Arc from:

• String literal: Arc::from("sensors/temperature")
• Owned String: Arc::from(string.as_str())

pub fn build(self) -> Router

Build the router

Consumes the builder and returns a configured Router.

pub fn route_count(&self) -> usize

Get the number of routes that will be created

Trait Implementations

impl Default for RouterBuilder

fn default() -> Self

Returns the “default value” for a type.