Function build_unix_stream_source

pub fn build_unix_stream_source<D, F, E>(
    listen_path: PathBuf,
    socket_file_mode: Option<u32>,
    decoder: D,
    handle_events: impl Fn(&mut [Event], Option<Bytes>) + Clone + Send + Sync + 'static,
    shutdown: ShutdownSignal,
    out: SourceSender,
) -> Result<Source>
where
    D: Decoder<Item = (F, usize), Error = E> + Clone + Send + 'static,
    E: StreamDecodingError + Display + Send,
    F: Into<SmallVec<[Event; 1]>> + Send,

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).