Struct Partition 

pub struct Partition { /* private fields */ }

A single partition backed by a memory lease.

Implementations

impl Partition

pub fn new(capacity: usize, stride: usize) -> Result<Self>

Create a new partition with the given capacity and slot stride.

Acquires a memory lease large enough for the header plus all slots.

pub fn append(&mut self, key: Option<&[u8]>, value: &[u8]) -> Result<u64>

Append a message to the partition.

The message’s offset and timestamp fields are set automatically. Returns the assigned offset, or CapacityExceeded if the serialized message exceeds the slot stride.

pub fn read_at(&self, offset: u64) -> Result<Option<Message>>

Read the message at the given absolute offset.

Returns None if the offset has been overwritten (wrapped) or is beyond the current write position.

pub fn next_offset(&self) -> u64

Returns the next offset that will be assigned.

pub fn oldest_offset(&self) -> u64

Returns the oldest available offset (messages before this have been overwritten).

pub fn len(&self) -> usize

Returns the number of messages currently retained in the ring buffer.

pub fn is_empty(&self) -> bool

Returns true if no messages are in the partition.

pub fn capacity(&self) -> usize

Returns the slot capacity of this partition.