Struct StreamRouter 

pub struct StreamRouter { /* private fields */ }

Stream message router with content-, topic-, and header-based routing, round-robin distribution, priority ordering, and a dead-letter queue.

Implementations

impl StreamRouter

pub fn new(config: RouterConfig) -> Self

Create a new router with the given configuration.

pub fn with_defaults() -> Self

Create a router with default configuration.

pub fn add_rule(&mut self, rule: RoutingRule) -> Result<(), RouterError>

Add a routing rule. Rules are kept sorted by descending priority.

pub fn remove_rule(&mut self, rule_id: &str) -> Result<RoutingRule, RouterError>

Remove a routing rule by ID.

pub fn update_rule(&mut self, rule: RoutingRule) -> Result<(), RouterError>

Update an existing rule in place.

pub fn set_rule_enabled( &mut self, rule_id: &str, enabled: bool, ) -> Result<(), RouterError>

Enable or disable a rule.

pub fn stats(&self) -> &RoutingStats

Return a snapshot of current routing statistics.

pub fn active_rule_count(&self) -> usize

Return the number of active (enabled) rules.

pub fn rule_count(&self) -> usize

Return total number of rules.

pub fn dlq(&self) -> &VecDeque<RoutableMessage>

Return the dead-letter queue contents.

pub fn pop_dlq(&mut self) -> Option<RoutableMessage>

Pop the oldest dead-lettered message.

pub fn clear_dlq(&mut self)

Clear all dead-lettered messages.

pub fn route(&mut self, message: RoutableMessage) -> RoutingOutcome

Route a single message through the rule chain.

The first matching enabled rule (by priority) wins. If no rule matches, the message is dead-lettered (if DLQ is enabled).

pub fn route_batch( &mut self, messages: Vec<RoutableMessage>, ) -> Vec<RoutingOutcome>

Route a batch of messages. Returns one outcome per message.

pub fn reset_stats(&mut self)

Reset statistics counters to zero.

pub fn rule_ids(&self) -> Vec<&str>

Return all rule IDs in priority order (highest first).

pub fn get_rule(&self, rule_id: &str) -> Option<&RoutingRule>

Return a reference to a rule by ID, if it exists.