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

decompression

Re-export of the shared decompression limits.

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.

max_decompressed_size_bytes

Returns the currently configured decompressed payload size cap.

set_max_decompressed_size_bytes

Override the global decompressed payload size cap. Must be called before any sources start.