Struct TopicManager 

pub struct TopicManager { /* private fields */ }

Topic manager

Implementations

impl TopicManager

pub fn new(config: Arc<ControllerConfig>) -> Self

Create a new topic manager

pub async fn start(&self) -> Result<()>

Start the topic manager

pub async fn shutdown(&self) -> Result<()>

Shutdown the topic manager

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

Create a topic from config

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

Update a topic from config

pub async fn create_or_update_topic(&self, info: TopicInfo) -> Result<()>

Create or update a topic

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

Delete a topic

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

Get topic information

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

List all topics

pub async fn list_topics_by_broker(&self, broker_name: &str) -> Vec<TopicInfo>

List topics by broker