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 and recover any existing topics from disk

pub fn new_with_tiered_storage( config: Config, tiered_storage: Arc<TieredStorage>, ) -> Self

Create a new topic manager with tiered storage support

pub fn has_tiered_storage(&self) -> bool

Check if tiered storage is enabled

pub fn tiered_storage_stats(&self) -> Option<TieredStorageStatsSnapshot>

Get tiered storage statistics

pub async fn recover(&self) -> Result<usize>

Initialize and recover topics from disk This should be called after construction to restore persisted topics

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 (race-safe: uses write lock directly)

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

pub async fn add_partitions( &self, name: &str, new_partition_count: u32, ) -> Result<u32>

Add partitions to an existing topic.

Increases the partition count of the topic to new_partition_count. Returns the number of partitions actually added.

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.