Struct nakadion::streaming_client::RawLine

pub struct RawLine {
    pub bytes: Vec<u8>,
    pub received_at: Instant,
}

A line as received from Nakadi plus a timestamp.

Fields

bytes: Vec<u8>

The bytes reveived as a line from Nakadi

received_at: Instant

The timestamp when this line was received

Trait Implementations