Struct IpcPayload 

pub struct IpcPayload(/* private fields */);

A byte buffer holding an Arrow IPC stream, ready to decode.

A dora-owned wrapper: the receive path needs to hand the decoder a buffer whose backing allocation it does not copy, but the Arrow buffer type that makes that possible must not appear in dora’s frozen public API (it would pin 1.x to one Arrow major — see docs/plan-arrow-version-decoupling.md). Construct one from the payload you have; decoding is zero-copy when the payload is 64-byte aligned, which dora’s own 128-byte-aligned and page-aligned shared-memory payloads always are.

Implementations

impl IpcPayload

pub fn from_aligned_vec(data: AVec<u8, ConstAlign<128>>) -> Self

Wrap a 128-byte-aligned payload buffer without copying it.

pub fn from_vec(data: Vec<u8>) -> Self

Take ownership of a Vec payload without copying it.

A plain Vec carries no alignment guarantee, so the decoder may have to realign individual buffers; use from_aligned_vec on the hot path.

pub fn from_slice(data: &[u8]) -> Self

Copy a payload out of a slice.

pub fn len(&self) -> usize

The payload length in bytes.

pub fn is_empty(&self) -> bool

Whether the payload is empty.

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

The payload bytes.

Trait Implementations

impl Clone for IpcPayload

fn clone(&self) -> IpcPayload

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IpcPayload

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

Formats the value using the given formatter.