Struct LogManager 

pub struct LogManager { /* private fields */ }

Implementations

impl LogManager

pub async fn new( base_dir: PathBuf, topic: &str, partition: u32, max_segment_size: u64, ) -> Result<Self>

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

pub async fn read(&self, offset: u64, max_bytes: usize) -> Result<Vec<Message>>

pub fn earliest_offset(&self) -> u64

pub async fn recover_next_offset(&self) -> Result<u64>

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

Flush all segments to disk ensuring durability

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

Find the first offset with timestamp >= target_timestamp (milliseconds since epoch) Scans through segments to find the earliest message matching the timestamp. Returns None if no matching offset is found.

Trait Implementations

impl Debug for LogManager

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

Formats the value using the given formatter.