Struct DataPacket 

pub struct DataPacket {
    pub node_id: u64,
    pub port: u32,
    pub timestamp_ms: u64,
    pub data: Vec<u8>,
    pub is_eos: bool,
}

A unit of data travelling between two ports in the processing graph.

Fields

node_id: u64

ID of the node that produced this packet.

port: u32

Output port index on the producing node.

timestamp_ms: u64

Presentation timestamp in milliseconds.

data: Vec<u8>

Raw payload bytes.

is_eos: bool

If true this is the last packet in the stream.

Implementations

impl DataPacket

pub fn new(node_id: u64, port: u32, timestamp_ms: u64, data: Vec<u8>) -> Self

Creates a normal (non-EOS) data packet.

pub fn eos(node_id: u64, port: u32, timestamp_ms: u64) -> Self

Creates an end-of-stream sentinel packet with an empty payload.

pub fn size_bytes(&self) -> usize

Returns the size of the payload in bytes.

pub fn is_end_of_stream(&self) -> bool

Returns true if this is an end-of-stream packet.

Trait Implementations

impl Clone for DataPacket

fn clone(&self) -> DataPacket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataPacket

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

Formats the value using the given formatter.