Add k8sevents receiver (#1657)

signalfx · Jun 9, 2022 · 899060e · 899060e
1 parent f8014fe
commit 899060e
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,11 @@
 
 ## Unreleased
 
+### 🚀 New components 🚀
+
+- [`k8sevents` receiver](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/k8seventsreceiver)
+  to collect Kubernetes events in OpenTelemetry semantics (#1641)
+
 ## v0.52.2
 
 ### 💡 Enhancements 💡

diff --git a/docs/components.md b/docs/components.md
@@ -46,7 +46,8 @@ new release. In addition, any of these components may be removed prior to the
 | [journald](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/journaldreceiver)         |            |                                                                                                     |            |
 | [kafka](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/kafkareceiver)               |            |                                                                                                     |            |
 | [kafkametrics](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/kafkametricsreceiver) |            |                                                                                                     |            |
+| [k8s_events](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/k8seventsreceiver)      |            |                                                                                                     |            |
 | [mongodbatlas](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/mongodbatlasreceiver) |            |                                                                                                     |            |
-| [statsd](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/statsdreceiver)
-| [syslog](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/syslogreceiver)             |            |                                                                                                     |            ||            |                                                                                                     |            |
+| [statsd](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/statsdreceiver)             |            |                                                                                                     |            |
+| [syslog](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/syslogreceiver)             |            |                                                                                                     |            |
 | [tcplog](https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/main/receiver/tcplogreceiver)             |            |                                                                                                     |            |
diff --git a/go.mod b/go.mod
@@ -49,6 +49,7 @@ require (
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/jaegerreceiver v0.52.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/journaldreceiver v0.52.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver v0.52.0
+	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8seventsreceiver v0.52.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver v0.52.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkareceiver v0.52.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver v0.52.0

diff --git a/go.sum b/go.sum
@@ -1607,6 +1607,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/receiver/journaldrecei
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/journaldreceiver v0.52.0/go.mod h1:7r5uaF2T2ObhmqsVxSvowOo7K933+33nvYanTSTMsIg=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver v0.52.0 h1:cuFbr9glae/qYilUFal1QFGFkrABHIoxH8cFOLMY0I0=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver v0.52.0/go.mod h1:XInc0uzMRCCCC4fsnmYG2k4oik6qme0UIgVG4bbq3Kc=
+github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8seventsreceiver v0.52.0 h1:MvrhtbySbgfC98lyh9Av9VsmqldiW5el8UuA/q7W2eI=
+github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8seventsreceiver v0.52.0/go.mod h1:OP80JIHjlQsaCn4UKG4L1KLhJdAv6rQKODv1khWj4yo=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver v0.52.0 h1:sm+m0yiVgNAX2cFcgYw6NKwHzehktgl9r2XXA0AmPcc=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver v0.52.0/go.mod h1:5yoVCfVtMHf6cqPpUAV3VageoZkh7dYcK0/PwYD62+E=
 github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkareceiver v0.52.0 h1:3C8l3Cu04HEhbcOP73HNs8a5C3jusIh1rktmKBa8gCo=

diff --git a/internal/components/components.go b/internal/components/components.go
@@ -50,6 +50,7 @@ import (
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/jaegerreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/journaldreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver"
+	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8seventsreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkareceiver"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver"
@@ -113,6 +114,7 @@ func Get() (component.Factories, error) {
 		jaegerreceiver.NewFactory(),
 		journaldreceiver.NewFactory(),
 		k8sclusterreceiver.NewFactory(),
+		k8seventsreceiver.NewFactory(),
 		kafkametricsreceiver.NewFactory(),
 		kafkareceiver.NewFactory(),
 		kubeletstatsreceiver.NewFactory(),

diff --git a/internal/components/components_test.go b/internal/components/components_test.go
@@ -50,6 +50,7 @@ func TestDefaultComponents(t *testing.T) {
 		"jaeger",
 		"journald",
 		"k8s_cluster",
+		"k8s_events",
 		"kafka",
 		"kafkametrics",
 		"kubeletstats",