From e7194ffe655d991dca0716a8a413ff58f2a90d9f Mon Sep 17 00:00:00 2001 From: Florian Apolloner Date: Sat, 21 Dec 2024 15:27:03 +0100 Subject: [PATCH] Actually allow log namespacing when using the syslog source. --- src/sources/syslog.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/sources/syslog.rs b/src/sources/syslog.rs index acd705daff33c..3991d39ef5fd3 100644 --- a/src/sources/syslog.rs +++ b/src/sources/syslog.rs @@ -236,7 +236,7 @@ impl SourceConfig for SyslogConfig { Deserializer::Syslog( SyslogDeserializerConfig::from_source(SyslogConfig::NAME).build(), ), - ); + ).with_log_namespace(log_namespace); build_unix_stream_source( path, @@ -293,7 +293,7 @@ impl TcpSource for SyslogTcpSource { Decoder::new( Framer::OctetCounting(OctetCountingDecoder::new_with_max_length(self.max_length)), Deserializer::Syslog(SyslogDeserializerConfig::from_source(SyslogConfig::NAME).build()), - ) + ).with_log_namespace(self.log_namespace) } fn handle_events(&self, events: &mut [Event], host: SocketAddr) { @@ -347,7 +347,7 @@ pub fn udp( Deserializer::Syslog( SyslogDeserializerConfig::from_source(SyslogConfig::NAME).build(), ), - ), + ).with_log_namespace(log_namespace), ) .take_until(shutdown) .filter_map(|frame| {