Function vector::sources::util::build_unix_stream_source

pub fn build_unix_stream_source(
    listen_path: PathBuf,
    socket_file_mode: Option<u32>,
    decoder: Decoder,
    handle_events: impl Fn(&mut [Event], Option<Bytes>) + Clone + Send + Sync + 'static,
    shutdown: ShutdownSignal,
    out: SourceSender,
) -> Result<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).