Struct SubscriptionIndex 

pub struct SubscriptionIndex { /* private fields */ }

Implementations

impl SubscriptionIndex

pub const fn new() -> Self

pub fn is_empty(&self) -> bool

pub fn subscribe(&mut self, peer: PeerKey, prefix: Bytes)

Adds a subscription for peer to prefix.

Complexity:

• O(log N) to find
• O(N) for insertion shift in the vec (acceptable for typical ZMQ sizes)

pub fn unsubscribe(&mut self, peer: PeerKey, prefix: &Bytes)

Removes a subscription for peer from prefix.

pub fn remove_peer_everywhere(&mut self, peer: PeerKey)

Remove peer from every prefix (used on disconnect).

Complexity: O(N) scan, acceptable on churn events.

pub fn match_topic(&self, topic: &[u8]) -> SmallVec<[PeerKey; 16]>

Match a topic against all subscriptions.

Returns a deduplicated list of PeerKeys.

Hot path characteristics:

• Forward scan over sorted prefixes.
• Early exit when prefix > topic lexicographically (cannot be a prefix).
• Starts-with check for actual prefix match.

Trait Implementations

impl Debug for SubscriptionIndex

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

Formats the value using the given formatter.

impl Default for SubscriptionIndex

fn default() -> SubscriptionIndex

Returns the “default value” for a type.