Struct nakadion::handler::BatchMeta [−][src]
#[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,
}
Expand description
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)
This struct is marked as 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
Auto Trait Implementations
impl<'a> RefUnwindSafe for BatchMeta<'a>
impl<'a> UnwindSafe for BatchMeta<'a>
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