Expand description
SubscriptionRouter — topic/type-based message routing with subscription management, filter evaluation, and delivery tracking.
Routes incoming RoutingMessages to registered Subscriptions using
topic matching and filter evaluation. Deliveries are tracked in a bounded
VecDeque-backed log.
§Design highlights
- Topic matching: exact match or wildcard (
*). - Filter evaluation: composable
SubscriptionFilterpredicates. - Delivery log: bounded at a configurable capacity; oldest entries are evicted when full.
- No
unwrap(): all fallible operations surface errors explicitly.
Structs§
- Delivery
Record - Audit record written whenever the router attempts delivery.
- Message
Topic - Newtype wrapper for topic identifiers used by
SubscriptionRouter. - Routing
Message - A message travelling through
SubscriptionRouter. - SubRouter
Stats - Point-in-time statistics snapshot for
SubscriptionRouter. - Subscription
- A subscriber registration in
SubscriptionRouter. - Subscription
Router - Topic/type-based message routing engine.
Enums§
- Subscription
Filter - A composable predicate for filtering
RoutingMessages.
Functions§
- fnv1a_
64 - Compute an FNV-1a 64-bit hash over an arbitrary byte slice.