Struct Topic 

pub struct Topic { /* private fields */ }

Represents a topic with multiple partitions

Implementations

impl Topic

pub async fn new( config: &Config, name: String, num_partitions: u32, ) -> Result<Self>

Create a new topic with the specified number of partitions

pub fn name(&self) -> &str

Get the topic name

pub fn num_partitions(&self) -> usize

Get the number of partitions

pub fn partition(&self, partition_id: u32) -> Result<Arc<Partition>>

Get a specific partition

pub async fn append(&self, partition_id: u32, message: Message) -> Result<u64>

Append a message to a specific partition

pub async fn read( &self, partition_id: u32, start_offset: u64, max_messages: usize, ) -> Result<Vec<Message>>

Read messages from a specific partition

pub fn all_partitions(&self) -> Vec<Arc<Partition>>

Get all partitions

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

Flush all partitions to disk ensuring durability

pub async fn find_offset_for_timestamp( &self, partition_id: u32, target_timestamp: i64, ) -> Result<Option<u64>>

Find the first offset with timestamp >= target_timestamp (milliseconds since epoch) Returns None if no matching offset is found.

Trait Implementations

impl Debug for Topic

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

Formats the value using the given formatter.