Struct SourceSenderItem 

pub struct SourceSenderItem {
    pub events: EventArray,
    pub send_reference: Instant,
}

SourceSenderItem is a thin wrapper around EventArray used to track the send duration of a batch.

This is needed because the send duration is calculated as the difference between when the batch is sent from the origin component to when the batch is enqueued on the receiving component’s input buffer. For sources in particular, this requires the batch to be enqueued on two channels: the origin component’s pump channel and then the receiving component’s input buffer.

Fields

events: EventArray

The batch of events to send.

send_reference: Instant

Reference instant used to calculate send duration.

Trait Implementations

impl AddBatchNotifier for SourceSenderItem

fn add_batch_notifier(&mut self, notifier: BatchNotifier)

Adds a single shared batch notifier to this type.

impl ByteSizeOf for SourceSenderItem

fn allocated_bytes(&self) -> usize

Returns the allocated bytes of this type

fn size_of(&self) -> usize

Returns the in-memory size of this type

impl Debug for SourceSenderItem

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

Formats the value using the given formatter.

impl EstimatedJsonEncodedSizeOf for SourceSenderItem

fn estimated_json_encoded_size_of(&self) -> JsonSize

impl EventContainer for SourceSenderItem

type IntoIter = EventArrayIntoIter

The type of Iterator used to turn this container into events.

fn len(&self) -> usize

The number of events in this container.

fn into_events(self) -> Self::IntoIter

Turn this container into an iterator over Event.

fn is_empty(&self) -> bool

Is this container empty?

impl EventCount for SourceSenderItem

fn event_count(&self) -> usize

impl From<SourceSenderItem> for EventArray

fn from(val: SourceSenderItem) -> Self

Converts to this type from the input type.