Struct SourceSender 

pub struct SourceSender { /* private fields */ }

Implementations

impl SourceSender

pub fn builder() -> Builder

pub async fn send_event( &mut self, event: impl Into<EventArray>, ) -> Result<(), SendError>

Send an event to the default output.

This internally handles emitting [EventsSent] and [ComponentEventsDropped] events.

pub async fn send_event_stream<S, E>( &mut self, events: S, ) -> Result<(), SendError>

where S: Stream<Item = E> + Unpin, E: Into<Event> + ByteSizeOf,

Send a stream of events to the default output.

This internally handles emitting [EventsSent] and [ComponentEventsDropped] events.

pub async fn send_batch<I, E>(&mut self, events: I) -> Result<(), SendError>

where E: Into<Event> + ByteSizeOf, I: IntoIterator<Item = E>, <I as IntoIterator>::IntoIter: ExactSizeIterator,

Send a batch of events to the default output.

This internally handles emitting [EventsSent] and [ComponentEventsDropped] events.

pub async fn send_batch_named<I, E>( &mut self, name: &str, events: I, ) -> Result<(), SendError>

where E: Into<Event> + ByteSizeOf, I: IntoIterator<Item = E>, <I as IntoIterator>::IntoIter: ExactSizeIterator,

Send a batch of events event to a named output.

This internally handles emitting [EventsSent] and [ComponentEventsDropped] events.

Trait Implementations

impl Clone for SourceSender

fn clone(&self) -> SourceSender

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SourceSender

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

Formats the value using the given formatter.