Trait vector::sources::util::http::HttpSource

pub trait HttpSource: Clone + Send + Sync + 'static {
    // Required method
    fn build_events(
        &self,
        body: Bytes,
        header_map: &HeaderMap,
        query_parameters: &HashMap<String, String>,
        path: &str,
    ) -> Result<Vec<Event>, ErrorMessage>;

    // Provided methods
    fn enrich_events(
        &self,
        _events: &mut [Event],
        _request_path: &str,
        _headers_config: &HeaderMap,
        _query_parameters: &HashMap<String, String>,
        _source_ip: Option<&SocketAddr>,
    ) { ... }
    fn decode(
        &self,
        encoding_header: Option<&str>,
        body: Bytes,
    ) -> Result<Bytes, ErrorMessage> { ... }
    fn run(
        self,
        address: SocketAddr,
        path: &str,
        method: HttpMethod,
        response_code: StatusCode,
        strict_path: bool,
        tls: &Option<TlsEnableableConfig>,
        auth: &Option<HttpSourceAuthConfig>,
        cx: SourceContext,
        acknowledgements: SourceAcknowledgementsConfig,
        keepalive_settings: KeepaliveConfig,
    ) -> Result<Source> { ... }
    fn enable_source_ip(&self) -> bool { ... }
}

Required Methods

fn build_events( &self, body: Bytes, header_map: &HeaderMap, query_parameters: &HashMap<String, String>, path: &str, ) -> Result<Vec<Event>, ErrorMessage>

Provided Methods

fn enrich_events( &self, _events: &mut [Event], _request_path: &str, _headers_config: &HeaderMap, _query_parameters: &HashMap<String, String>, _source_ip: Option<&SocketAddr>, )

fn decode( &self, encoding_header: Option<&str>, body: Bytes, ) -> Result<Bytes, ErrorMessage>

fn run( self, address: SocketAddr, path: &str, method: HttpMethod, response_code: StatusCode, strict_path: bool, tls: &Option<TlsEnableableConfig>, auth: &Option<HttpSourceAuthConfig>, cx: SourceContext, acknowledgements: SourceAcknowledgementsConfig, keepalive_settings: KeepaliveConfig, ) -> Result<Source>

fn enable_source_ip(&self) -> bool

Object Safety

This trait is not object safe.

Implementors