Struct MmapBatch 

pub struct MmapBatch { /* private fields */ }

Available on non-crate feature mmap only.

Fallback batch implementation

Implementations

impl MmapBatch

pub fn from_jsonl_file(path: &Path) -> Result<Self>

Create a batch from a JSONL file

pub fn get(&self, index: usize) -> Option<&[u8]>

Get a message by index

pub fn iter(&self) -> impl Iterator<Item = (&Arc<MessageId>, &[u8])> + '_

Iterate over all messages in the batch

pub fn len(&self) -> usize

Get the number of messages in the batch

pub fn is_empty(&self) -> bool

Check if the batch is empty

pub async fn from_jsonl_file_async(path: &Path) -> Result<Self>

Create a batch from a JSONL file (ASYNC - Non-blocking fallback!)

This is the async version of from_jsonl_file for the non-mmap fallback that uses tokio::task::spawn_blocking to avoid blocking the async runtime.

Trait Implementations

impl Debug for MmapBatch

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

Formats the value using the given formatter.