Module engine

Structs

• Delivery
  One fan-out of an Envelope to one subscription.
• Engine
  Shared, protocol-neutral pub/sub router.
• EngineStats
  Running counters for publish fan-out.
• PublishOutcome
  Result of one Engine::publish fan-out.
• State 🔒
  Indexes used to find subscribers without scanning every key.
• SubscriberKey
  Composite key for a subscription owned by one adapter.
• Subscription 🔒
  One registered subscriber: the route it matches and the channel it owns.

Enums

• EngineError
  Errors from Engine::subscribe and Engine::unsubscribe.

Constants

• DEFAULT_CHANNEL_CAPACITY
  Capacity of each subscriber delivery channel.

Functions

• collect_targets 🔒
  Subscribers that should see a publish on route.
• insert_index 🔒
  Indexes key under exact or wildcard, according to route.type_hint.
• remove_subscription 🔒
  Drops key from every index. Err if it was not registered.