Struct TopicManager 

pub struct TopicManager { /* private fields */ }

Manages topic lifecycle: create, open, delete.

Implementations

impl TopicManager

pub fn new() -> Self

Create a new empty topic manager.

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

Create a new topic with the given name and configuration.

Returns an error if the topic already exists.

pub fn open(&self, name: &str) -> Option<&Topic>

Open an existing topic by name.

pub fn open_mut(&mut self, name: &str) -> Option<&mut Topic>

Open an existing topic mutably by name.

pub fn delete(&mut self, name: &str) -> bool

Delete a topic by name. Returns true if the topic existed.

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

Returns all topic names.

pub fn len(&self) -> usize

Returns the number of topics.

pub fn is_empty(&self) -> bool

Returns true if there are no topics.

Trait Implementations

impl Default for TopicManager

fn default() -> Self

Returns the “default value” for a type.