Struct Segment 

pub struct Segment { /* private fields */ }

Represents a segment of the log on disk A segment consists of a .log file (data) and a .index file (sparse index)

Implementations

impl Segment

pub fn new(dir: &Path, base_offset: u64) -> Result<Self>

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

Append a message to the segment

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

Flush segment data to disk ensuring durability

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

Read a batch of messages starting from a given offset

pub fn size(&self) -> u64

pub fn base_offset(&self) -> u64

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

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

Find the first offset with timestamp >= target_timestamp Uses linear scan through the segment (timestamps may not be monotonic due to clock skew) Returns None if no matching offset is found

pub async fn timestamp_bounds(&self) -> Result<Option<(i64, i64)>>

Get the timestamp range of messages in this segment Returns (min_timestamp, max_timestamp) in milliseconds since epoch Useful for quickly determining if a segment might contain a target timestamp

Trait Implementations

impl Debug for Segment

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

Formats the value using the given formatter.