Struct nakadion::components::connector::EventStreamBatch

pub struct EventStreamBatch { /* fields omitted */ }

An analyzed line (frame) from Nakadi

See also Nakadi Manual

Implementations

impl EventStreamBatch

pub fn new<T: Into<Bytes>>(
    bytes: T
) -> Result<EventStreamBatch, ParseBatchError>

pub fn try_from_slice<T: AsRef<[u8]>>(
    slice: T
) -> Result<EventStreamBatch, ParseBatchError>

pub fn try_from_frame(
    frame: NakadiFrame
) -> Result<EventStreamBatch, ParseBatchError>

pub fn with_frame_id(self, frame_id: usize) -> Self

pub fn frame_id(&self) -> usize

pub fn frame_started_at(&self) -> Instant

pub fn frame_completed_at(&self) -> Instant

pub fn bytes(&self) -> Bytes

pub fn cursor_str(&self) -> &str

pub fn cursor_bytes(&self) -> Bytes

pub fn partition_bytes(&self) -> Bytes

pub fn partition_str(&self) -> &str

pub fn event_type_bytes(&self) -> Bytes

pub fn event_type_str(&self) -> &str

pub fn to_event_type_partition(&self) -> EventTypePartition

pub fn events_bytes(&self) -> Option<Bytes>

pub fn events_str(&self) -> Option<&str>

pub fn info_bytes(&self) -> Option<Bytes>

pub fn info_str(&self) -> Option<&str>

pub fn is_keep_alive_line(&self) -> bool

pub fn has_events(&self) -> bool

pub fn n_events(&self) -> usize

pub fn has_info(&self) -> bool

pub fn cursor_deserialized<T: DeserializeOwned>(&self) -> Result<T, Error>

pub fn stats(&self) -> EventStreamBatchStats

Trait Implementations

impl Debug for EventStreamBatch

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

Formats the value using the given formatter.