Struct nakadion::handler::BatchMeta

#[non_exhaustive]pub struct BatchMeta<'a> {
    pub stream_id: StreamId,
    pub cursor: &'a SubscriptionCursor,
    pub frame_started_at: Instant,
    pub frame_completed_at: Instant,
    pub frame_id: usize,
    pub n_events: usize,
}

Information on the current batch passed to a BatchHandler.

The frame_id is monotonically increasing for each BatchHandler within a stream(same StreamId) as long a s a dispatch strategy which keeps the ordering of events is chosen. There may be gaps between the ids.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

stream_id: StreamId

cursor: &'a SubscriptionCursor

frame_started_at: Instant

Timestamp when the first byte was received

frame_completed_at: Instant

Timestamp when the frame was completed

frame_id: usize

n_events: usize

Trait Implementations

impl<'a> Debug for BatchMeta<'a>

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

Formats the value using the given formatter.