Struct Partition 

pub struct Partition { /* private fields */ }

A single partition within a topic

Implementations

impl Partition

pub async fn new(config: &Config, topic: &str, id: u32) -> Result<Self>

Create a new partition

pub fn id(&self) -> u32

Get the partition ID

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

Append a message to the partition Lock-free implementation using AtomicU64 for 5-10x throughput

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

Read messages from a given offset

pub async fn latest_offset(&self) -> u64

Get the latest offset

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

pub async fn message_count(&self) -> usize

pub async fn append_batch(&self, messages: Vec<Message>) -> Result<Vec<u64>>

Batch append multiple messages for 20-50x throughput improvement Single fsync per batch instead of per-message

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

Flush partition data 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) Returns None if no matching offset is found.

Trait Implementations

impl Debug for Partition

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

Formats the value using the given formatter.