Struct nakadion::components::connector::NakadiFrame [−][src]
pub struct NakadiFrame {
pub bytes: Bytes,
pub started_at: Instant,
pub completed_at: Instant,
pub frame_id: usize,
}
Expand description
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
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for NakadiFrame
impl Send for NakadiFrame
impl Sync for NakadiFrame
impl Unpin for NakadiFrame
impl UnwindSafe for NakadiFrame
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more