Module vector::sources::util

Re-exports

• pub use multiline_config::MultilineConfig;
• pub use unix::change_socket_permissions;
• pub use self::http::add_query_parameters;
• pub use self::http::decode;
• pub use self::http::ErrorMessage;
• pub use self::http::HttpSource;
• pub use self::http::HttpSourceAuthConfig;

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.

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.