Struct TopicConfigManager 

pub struct TopicConfigManager { /* private fields */ }

Topic configuration manager

Manages per-topic configurations with thread-safe access.

Implementations

impl TopicConfigManager

pub fn new() -> Self

Create a new topic config manager

pub fn get_or_default(&self, topic: &str) -> TopicConfig

Get or create config for a topic

pub fn get(&self, topic: &str) -> Option<TopicConfig>

Get config for a topic

pub fn set(&self, topic: &str, config: TopicConfig)

Set config for a topic

pub fn apply_changes( &self, topic: &str, changes: &[(String, Option<String>)], ) -> Result<usize, String>

Apply configuration changes to a topic

pub fn remove(&self, topic: &str)

Remove config for a topic (reverts to defaults)

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

List all configured topics

pub fn describe( &self, topics: &[String], ) -> Vec<(String, HashMap<String, ConfigValue>)>

Describe configurations for topics

Trait Implementations

impl Default for TopicConfigManager

fn default() -> Self

Returns the “default value” for a type.