Struct TopicManager 

pub struct TopicManager { /* private fields */ }

Manages all topics in the system

Implementations

impl TopicManager

pub fn new(config: Config) -> Self

Create a new topic manager

pub async fn create_topic( &self, name: String, num_partitions: Option<u32>, ) -> Result<Arc<Topic>>

Create a new topic

pub async fn get_topic(&self, name: &str) -> Result<Arc<Topic>>

Get a topic by name

pub async fn get_or_create_topic(&self, name: String) -> Result<Arc<Topic>>

Get or create a topic

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

List all topics

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

Delete a topic

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

Flush all topics to disk ensuring durability during shutdown

Trait Implementations

impl Clone for TopicManager

fn clone(&self) -> TopicManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.