Struct nakadion::components::streams::NakadiFrame

pub struct NakadiFrame {
    pub bytes: Bytes,
    pub started_at: Instant,
    pub completed_at: Instant,
    pub frame_id: usize,
}

A frame (line) from Nakadi

Fields

bytes: Bytes

started_at: Instant

Timestamp when the first byte was received

completed_at: Instant

Timestamp when the frame was completed

frame_id: usize

Implementations

impl NakadiFrame

pub fn new(
    bytes: Vec<u8>,
    started_at: Instant,
    completed_at: Instant,
    frame_id: usize
) -> Self

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

Trait Implementations

impl AsRef<[u8]> for NakadiFrame

fn as_ref(&self) -> &[u8]

Performs the conversion.

impl Clone for NakadiFrame

fn clone(&self) -> NakadiFrame

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for NakadiFrame

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

Formats the value using the given formatter.