Struct TopicRouter 

pub struct TopicRouter { /* private fields */ }

Intelligent GossipSub topic manager with priority-based message queuing.

TopicRouter is Send + Sync and designed for concurrent use behind an Arc.

Example

use ipfrs_network::topic_router::{TopicRouter, TopicConfig, PrioritizedMessage};
use std::time::{Duration, Instant};

let router = TopicRouter::new();
router.register_topic("blocks", TopicConfig::default()).unwrap();

let msg = PrioritizedMessage {
    payload: b"hello".to_vec(),
    priority: 200,
    enqueued_at: Instant::now(),
    topic: "blocks".to_string(),
};
router.enqueue("blocks", msg).unwrap();
let popped = router.dequeue("blocks");
assert!(popped.is_some());

Implementations

impl TopicRouter

pub fn new() -> Self

Create a new, empty TopicRouter.

pub fn register_topic( &self, name: &str, config: TopicConfig, ) -> Result<(), TopicError>

Register a new topic with the given configuration.

Errors

Returns TopicError::AlreadyRegistered if the topic name has already been registered.

pub fn unregister_topic(&self, name: &str) -> Result<(), TopicError>

Unregister a topic and discard its queue and counters.

Errors

Returns TopicError::TopicNotFound if the topic has not been registered.

pub fn enqueue( &self, topic: &str, msg: PrioritizedMessage, ) -> Result<(), TopicError>

Enqueue a message on the given topic.

Errors

• TopicError::TopicNotFound — topic not registered
• TopicError::BelowThreshold — message priority below topic threshold (also counts as dropped)
• TopicError::QueueFull — queue at capacity (also counts as dropped)

pub fn dequeue(&self, topic: &str) -> Option<PrioritizedMessage>

Pop and return the highest-priority message from the topic’s queue.

Returns None if the topic does not exist or the queue is empty.

pub fn queue_depth(&self, topic: &str) -> usize

Returns the number of messages currently in the topic’s queue.

Returns 0 for unregistered topics.

pub fn message_count(&self, topic: &str) -> u64

Returns the total number of messages ever successfully enqueued on the topic (messages that were dropped are not counted here).

Returns 0 for unregistered topics.

pub fn all_topics(&self) -> Vec<String>

Returns a sorted list of all registered topic names.

pub fn stats(&self) -> TopicRouterStatsSnapshot

Returns a point-in-time statistics snapshot.

Trait Implementations

impl Default for TopicRouter

fn default() -> Self

Returns the “default value” for a type.