Struct CollectionRouteTable 

pub struct CollectionRouteTable { /* private fields */ }

Lookup table for per-collection transport routing

Maps collection names to their transport routing configuration. Collections not in this table fall through to legacy scoring via route_message().

Example

use peat_mesh::transport::{
    CollectionRouteTable, CollectionRouteConfig, CollectionTransportRoute,
    TransportType, MessagePriority,
};

let table = CollectionRouteTable::new()
    .with_collection(CollectionRouteConfig {
        collection: "telemetry".to_string(),
        route: CollectionTransportRoute::Fixed {
            transport_type: TransportType::BluetoothLE,
        },
        priority: MessagePriority::Normal,
    });

assert!(table.has_collection("telemetry"));
assert!(!table.has_collection("unknown"));

Implementations

impl CollectionRouteTable

pub fn new() -> CollectionRouteTable

Create an empty route table

pub fn with_collection( self, config: CollectionRouteConfig, ) -> CollectionRouteTable

Add a collection route configuration (builder pattern)

pub fn get(&self, collection: &str) -> Option<&CollectionRouteConfig>

Get the route config for a collection

pub fn has_collection(&self, collection: &str) -> bool

Check if a collection has a route configured

pub fn is_bypass(&self, collection: &str) -> bool

Check if a collection is configured for bypass routing

Trait Implementations

impl Clone for CollectionRouteTable

fn clone(&self) -> CollectionRouteTable

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CollectionRouteTable

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

Formats the value using the given formatter.

impl Default for CollectionRouteTable

fn default() -> CollectionRouteTable

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CollectionRouteTable

fn deserialize<__D>( __deserializer: __D, ) -> Result<CollectionRouteTable, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CollectionRouteTable

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.