Struct MmapMessage 

pub struct MmapMessage {
    pub id: Arc<MessageId>,
    pub data: Bytes,
    pub metadata: MessageMetadata,
}

Available on non-crate feature mmap only.

Fallback implementation using regular file I/O

Fields

id: Arc<MessageId>

Unique message identifier

data: Bytes

Message data as bytes

metadata: MessageMetadata

Message metadata

Implementations

impl MmapMessage

pub fn from_file( id: MessageId, path: &Path, offset: usize, length: Option<usize>, ) -> Result<Self>

Create a message by reading from a file

pub fn data(&self) -> &[u8]

Get the message data as a byte slice

pub fn to_bytes(&self) -> Bytes

Convert the message data to Bytes

pub fn parse_json<T>(&self) -> Result<T>

where T: for<'de> Deserialize<'de>,

Parse the message data as JSON

pub fn as_str(&self) -> Result<&str>

Get the message data as a string slice

pub async fn from_file_async( id: MessageId, path: &Path, offset: usize, length: Option<usize>, ) -> Result<Self>

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

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

Trait Implementations

impl Debug for MmapMessage

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

Formats the value using the given formatter.