Enum vector::sinks::VectorSink

pub enum VectorSink {
    Sink(Box<dyn Sink<EventArray, Error = ()> + Unpin + Send>),
    Stream(Box<dyn StreamSink<EventArray> + Send>),
}

Variants

Sink(Box<dyn Sink<EventArray, Error = ()> + Unpin + Send>)

Stream(Box<dyn StreamSink<EventArray> + Send>)

Implementations

impl VectorSink

pub async fn run( self, input: impl Stream<Item = EventArray> + Send, ) -> Result<(), ()>

Run the VectorSink

Errors

It is unclear under what conditions this function will error.

pub async fn run_events<I>(self, input: I) -> Result<(), ()>

where I: IntoIterator<Item = Event> + Send, <I as IntoIterator>::IntoIter: Send,

Run the VectorSink with a one-time Vec of Events, for use in tests

Errors

See VectorSink::run for errors.

pub fn into_sink(self) -> Box<dyn Sink<EventArray, Error = ()> + Unpin + Send>

Converts VectorSink into a futures::Sink

Panics

This function will panic if the self instance is not VectorSink::Sink.

pub fn into_stream(self) -> Box<dyn StreamSink<EventArray> + Send>

Converts VectorSink into a StreamSink

Panics

This function will panic if the self instance is not VectorSink::Stream.

pub fn from_event_sink( sink: impl Sink<Event, Error = ()> + Send + Unpin + 'static, ) -> VectorSink

👎Deprecated

Converts an event sink into a VectorSink

Deprecated in favor of VectorSink::from_event_streamsink. See vector/9261 for more info.

pub fn from_event_streamsink( sink: impl StreamSink<Event> + Send + 'static, ) -> VectorSink

Converts an event stream into a VectorSink

Trait Implementations

impl Debug for VectorSink

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

Formats the value using the given formatter.