Struct TopicRegistry 

pub struct TopicRegistry { /* private fields */ }

Central registry for tracking topics at runtime

Thread-safe registry that maintains information about all active topics, their publishers, and subscribers.

Implementations

impl TopicRegistry

pub fn new() -> Self

Create a new topic registry

pub async fn register_publisher( &self, topic: &str, node_id: &str, message_type: &str, )

Register a publisher for a topic

Arguments

• topic - Topic path
• node_id - Publishing node identifier
• message_type - Message type name

pub async fn register_subscriber( &self, topic: &str, node_id: &str, message_type: &str, )

Register a subscriber for a topic

Arguments

• topic - Topic path
• node_id - Subscribing node identifier
• message_type - Message type name

pub async fn unregister_publisher(&self, topic: &str, node_id: &str)

Unregister a publisher

pub async fn unregister_subscriber(&self, topic: &str, node_id: &str)

Unregister a subscriber

pub async fn unregister_node(&self, node_id: &str)

Unregister all topics for a node (when node stops)

pub async fn get_topic(&self, topic: &str) -> Option<TopicInfo>

Get information about a specific topic

pub async fn list_topics(&self) -> Vec<String>

List all registered topics

pub async fn get_all_topics(&self) -> Vec<TopicInfo>

Get all topic information

pub async fn find_by_message_type(&self, message_type: &str) -> Vec<TopicInfo>

Find topics by message type

pub async fn topics_published_by(&self, node_id: &str) -> Vec<String>

Find topics published by a node

pub async fn topics_subscribed_by(&self, node_id: &str) -> Vec<String>

Find topics subscribed to by a node

pub async fn topic_count(&self) -> usize

Get total number of topics

pub async fn validate(&self) -> Vec<String>

Validate the topic topology

Returns a list of validation issues:

• Topics with no publishers
• Topics with no subscribers
• Type mismatches

pub async fn stats(&self) -> TopologyStats

Get topology statistics

pub async fn export_dot(&self) -> String

Export topology as DOT graph (for Graphviz visualization)

pub async fn clear(&self)

Clear all registered topics (for testing)

Trait Implementations

impl Clone for TopicRegistry

fn clone(&self) -> TopicRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TopicRegistry

fn default() -> Self

Returns the “default value” for a type.