Trait vector::sinks::util::http::HttpSink

pub trait HttpSink: Send + Sync + 'static {
    type Input;
    type Output;
    type Encoder: HttpEventEncoder<Self::Input>;

    // Required methods
    fn build_encoder(&self) -> Self::Encoder;
    fn build_request(
        &self,
        events: Self::Output,
    ) -> impl Future<Output = Result<Request<Bytes>>> + Send;
}

Required Associated Types

type Input

type Output

type Encoder: HttpEventEncoder<Self::Input>

Required Methods

fn build_encoder(&self) -> Self::Encoder

fn build_request( &self, events: Self::Output, ) -> impl Future<Output = Result<Request<Bytes>>> + Send

Object Safety

This trait is not object safe.

Implementors

impl HttpSink for MezmoConfig

type Input = PartitionInnerBuffer<Value, PartitionKey>

type Output = PartitionInnerBuffer<Vec<Box<RawValue>>, PartitionKey>

type Encoder = MezmoEventEncoder