Module util 

Re-exports

pub use multiline_config::MultilineConfig;

pub use unix::change_socket_permissions;

pub use self::http::HttpSource;

pub use self::http::add_headers;

pub use self::http::add_query_parameters;

pub use self::http::decompress_body;

Modules

framestream

grpc

http

http_client

Common logic for sources that are HTTP clients.

multiline_config

net

unix

Structs

AfterRead

This wraps the inner socket and emits BytesReceived with the actual number of bytes read before handling framing.

EncodingConfig

Character set encoding.

LenientFramedRead

A wrapper around an FramedRead that silently ignores ConnectionReset errors if the frame buffer is empty.

Enums

Encoding

Content encoding.

Traits

AfterReadExt

Functions

build_unix_datagram_source

Returns a Source object corresponding to a Unix domain datagram socket. Passing in different functions for decoder and handle_events can allow for different source-specific logic (such as decoding syslog messages in the syslog source).

build_unix_stream_source

Returns a Source object corresponding to a Unix domain stream socket. Passing in different functions for decoder and handle_events can allow for different source-specific logic (such as decoding syslog messages in the syslog source).

decode_message

extract_tag_key_and_value

Extract a tag and it’s value from input string delimited by a colon character.