Struct EventFrame 

pub struct EventFrame;

Event frame format for packing multiple events in a single packet.

Format: [len: u32][data: [u8; len]]...

Events are concatenated with 4-byte length prefixes. No additional framing.

Implementations

impl EventFrame

pub const LEN_SIZE: usize = 4

Size of the length prefix

pub fn write_events(events: &[Bytes], buf: &mut BytesMut) -> usize

Write events to a buffer, returning the total bytes written.

Panics if any event exceeds u32::MAX bytes. Under normal production paths every event is well below MAX_PAYLOAD_SIZE (~8 KiB), but without the assertion an event larger than 4 GiB would silently truncate the length prefix and corrupt the framed stream — a panic is far preferable to silent data corruption on a framing boundary.

pub fn read_events(data: Bytes, count: u16) -> Vec<Bytes>

Read events from a buffer

pub fn calculate_size(events: &[Bytes]) -> usize

Calculate total size for events