Struct TopicManager 

pub struct TopicManager { /* private fields */ }

Topic manager for managing Pub/Sub topics.

Uses the google-cloud-pubsub 0.33 TopicAdmin client for topic management and tracks topics in a local cache.

Implementations

impl TopicManager

pub async fn new(project_id: impl Into<String>) -> Result<Self>

Creates a new topic manager.

pub async fn create_topic(&self, config: TopicConfig) -> Result<String>

Creates a new topic.

pub fn get_topic(&self, topic_name: &str) -> Option<String>

Gets a fully-qualified topic name by short name.

pub async fn delete_topic(&self, topic_name: &str) -> Result<()>

Deletes a topic.

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

Lists all topics in the project.

pub fn topic_exists(&self, topic_name: &str) -> bool

Checks if a topic exists.

pub fn topic_count(&self) -> usize

Gets the number of managed topics.

pub fn clear_cache(&self)

Clears all cached topics.

pub fn project_id(&self) -> &str

Gets the project ID.

pub async fn update_labels( &self, topic_name: &str, _labels: HashMap<String, String>, ) -> Result<()>

Updates topic labels.

pub async fn get_metadata(&self, topic_name: &str) -> Result<TopicMetadata>

Gets topic metadata.

pub async fn get_stats(&self, topic_name: &str) -> Result<TopicStats>

Gets topic statistics.

pub async fn test_publish(&self, topic_name: &str) -> Result<String>

Publishes a test message to verify topic connectivity.