From 41a968fb58ea18b4cc6c54694c8036cac915094b Mon Sep 17 00:00:00 2001 From: Pavlos Rontidis Date: Mon, 6 Jan 2025 11:33:18 -0500 Subject: [PATCH 1/4] fix(opentelemetry sink): input() should delegate to internal config input() --- src/sinks/opentelemetry/mod.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/sinks/opentelemetry/mod.rs b/src/sinks/opentelemetry/mod.rs index 4f716d3ff58bf..5568981235f5a 100644 --- a/src/sinks/opentelemetry/mod.rs +++ b/src/sinks/opentelemetry/mod.rs @@ -74,7 +74,9 @@ impl SinkConfig for OpenTelemetryConfig { } fn input(&self) -> Input { - Input::all() + match &self.protocol { + Protocol::Http(config) => config.input() + } } fn acknowledgements(&self) -> &AcknowledgementsConfig { From c8b05ae40b94835869bffa342d89be90d9e897cc Mon Sep 17 00:00:00 2001 From: Pavlos Rontidis Date: Mon, 6 Jan 2025 11:37:42 -0500 Subject: [PATCH 2/4] changelog --- changelog.d/22126.fix.md | 1 + 1 file changed, 1 insertion(+) create mode 100644 changelog.d/22126.fix.md diff --git a/changelog.d/22126.fix.md b/changelog.d/22126.fix.md new file mode 100644 index 0000000000000..58de5d9113e40 --- /dev/null +++ b/changelog.d/22126.fix.md @@ -0,0 +1 @@ +Fix `opentelemetry` sink input resolution. The sink is now using the underlying protocol to determine what inputs are accepted. From 072518bdbee11dc7e4e19ed365eb9633c6218196 Mon Sep 17 00:00:00 2001 From: Pavlos Rontidis Date: Mon, 6 Jan 2025 12:05:24 -0500 Subject: [PATCH 3/4] fix changelog --- changelog.d/22126.fix.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/changelog.d/22126.fix.md b/changelog.d/22126.fix.md index 58de5d9113e40..d9f7e9b451295 100644 --- a/changelog.d/22126.fix.md +++ b/changelog.d/22126.fix.md @@ -1 +1,3 @@ Fix `opentelemetry` sink input resolution. The sink is now using the underlying protocol to determine what inputs are accepted. + +authors: pront From d565e5db534ebd784c5977d60c09291f77d93b54 Mon Sep 17 00:00:00 2001 From: Pavlos Rontidis Date: Mon, 6 Jan 2025 12:23:18 -0500 Subject: [PATCH 4/4] fmt --- src/sinks/opentelemetry/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sinks/opentelemetry/mod.rs b/src/sinks/opentelemetry/mod.rs index 5568981235f5a..90d26da27e202 100644 --- a/src/sinks/opentelemetry/mod.rs +++ b/src/sinks/opentelemetry/mod.rs @@ -75,7 +75,7 @@ impl SinkConfig for OpenTelemetryConfig { fn input(&self) -> Input { match &self.protocol { - Protocol::Http(config) => config.input() + Protocol::Http(config) => config.input(), } }