Trait vector::sinks::util::sink::StreamSink

pub trait StreamSink<T> {
    // Required method
    fn run<'life0, 'async_trait>(
        self: Box<Self>,
        input: Pin<Box<dyn Stream<Item = T> + Send + 'life0>>,
    ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;
}

Required Methods

fn run<'life0, 'async_trait>( self: Box<Self>, input: Pin<Box<dyn Stream<Item = T> + Send + 'life0>>, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Implementors

impl StreamSink<Event> for FileSink

impl StreamSink<EventArray> for HumioMetricsSink

impl<S> StreamSink<Event> for DatadogEventsSink<S>

where S: Service<DatadogEventsRequest> + Send + 'static, S::Future: Send + 'static, S::Response: DriverResponse + Send + 'static, S::Error: Debug + Into<Error> + Send,

impl<S> StreamSink<Event> for LogSink<S>

where S: Service<LogApiRequest> + Send + 'static, S::Future: Send + 'static, S::Response: DriverResponse + Send + 'static, S::Error: Debug + Into<Error> + Send,

impl<S> StreamSink<Event> for ElasticsearchSink<S>

where S: Service<ElasticsearchRequest> + Send + 'static, S::Future: Send + 'static, S::Response: DriverResponse + Send + 'static, S::Error: Debug + Into<Error> + Send,

impl<S, R> StreamSink<Event> for KinesisSink<S, R>

where S: Service<BatchKinesisRequest<R>> + Send + 'static, S::Future: Send + 'static, S::Response: DriverResponse + Send + 'static, S::Error: Debug + Into<Error> + Send, R: Record + Send + Sync + Unpin + Clone + 'static,

impl<Svc> StreamSink<Event> for OpenDalSink<Svc>

where Svc: Service<OpenDalRequest> + Send + 'static, Svc::Future: Send + 'static, Svc::Response: DriverResponse + Send + 'static, Svc::Error: Debug + Into<Error> + Send,

impl<Svc, RB> StreamSink<Event> for AzureBlobSink<Svc, RB>

where Svc: Service<RB::Request> + Send + 'static, Svc::Future: Send + 'static, Svc::Response: DriverResponse + Send + 'static, Svc::Error: Debug + Into<Error> + Send, RB: RequestBuilder<(String, Vec<Event>)> + Send + Sync + 'static, RB::Error: Display + Send, RB::Request: Finalizable + MetaDescriptive + Send,

impl<Svc, RB> StreamSink<Event> for ChronicleSink<Svc, RB>

where Svc: Service<RB::Request> + Send + 'static, Svc::Future: Send + 'static, Svc::Response: DriverResponse + Send + 'static, Svc::Error: Debug + Into<Error> + Send, RB: RequestBuilder<(ChroniclePartitionKey, Vec<Event>)> + Send + Sync + 'static, RB::Error: Display + Send, RB::Request: Finalizable + MetaDescriptive + Send,

impl<Svc, RB> StreamSink<Event> for GcsSink<Svc, RB>

where Svc: Service<RB::Request> + Send + 'static, Svc::Future: Send + 'static, Svc::Response: DriverResponse + Send + 'static, Svc::Error: Debug + Into<Error> + Send, RB: RequestBuilder<(String, Vec<Event>)> + Send + Sync + 'static, RB::Error: Display + Send, RB::Request: Finalizable + MetaDescriptive + Send,

impl<Svc, RB> StreamSink<Event> for S3Sink<Svc, RB>

where Svc: Service<RB::Request> + Send + 'static, Svc::Future: Send + 'static, Svc::Response: DriverResponse + Send + 'static, Svc::Error: Debug + Into<Error> + Send, RB: RequestBuilder<(S3PartitionKey, Vec<Event>)> + Send + Sync + 'static, RB::Error: Display + Send, RB::Request: Finalizable + MetaDescriptive + Send,