added rabbitmq to the auto discovery mechanism

Signed-off-by: Samiur Arif <[email protected]>

cmd/otelcol/config/collector/config.d.linux/receivers/rabbitmq.discovery.yaml

@@ -0,0 +1,32 @@
+#####################################################################################
+# This file is generated by the Splunk Distribution of the OpenTelemetry Collector. #
+#                                                                                   #
+# It reflects the default configuration bundled in the Collector executable for use #
+# in discovery mode (--discovery) and is provided for reference or customization.   #
+# Please note that any changes made to this file will need to be reconciled during  #
+# upgrades of the Collector.                                                        #
+#####################################################################################
+# rabbitmq:
+#   enabled: true
+#   rule:
+#     docker_observer: type == "container" and any([name, image, command], {# matches "(?i)rabbitmq.*"}) and not (command matches "splunk.discovery")
+#     host_observer: type == "hostport" and command matches "(?i)rabbitmq.*" and not (command matches "splunk.discovery")
+#     k8s_observer: type == "port" and pod.name matches "(?i)rabbitmq.*"
+#   config:
+#     default:
+#       endpoint: '`endpoint`'
+#       username: splunk.discovery.default
+#       password: splunk.discovery.default
+#       collection_interval: 10s
+#   status:
+#     metrics:
+#       - status: successful
+#         strict: rabbitmq.consumer.count
+#         message: rabbitmq receiver is working!
+#     statements:
+#       - status: failed
+#         regexp: 'connect: network is unreachable'
+#         message: The container cannot be reached by the Collector. Make sure they're in the same network.
+#       - status: failed
+#         regexp: 'connect: connection refused'
+#         message: The container is refusing kafka server connections.

internal/confmapprovider/discovery/bundle/bundle.d/receivers/rabbitmq.discovery.yaml

@@ -0,0 +1,28 @@
+#####################################################################################
+#                               Do not edit manually!                               #
+# All changes must be made to associated .tmpl file before running 'make bundle.d'. #
+#####################################################################################
+rabbitmq:
+  enabled: true
+  rule:
+    docker_observer: type == "container" and any([name, image, command], {# matches "(?i)rabbitmq.*"}) and not (command matches "splunk.discovery")
+    host_observer: type == "hostport" and command matches "(?i)rabbitmq.*" and not (command matches "splunk.discovery")
+    k8s_observer: type == "port" and pod.name matches "(?i)rabbitmq.*"
+  config:
+    default:
+      endpoint: '`endpoint`'
+      username: splunk.discovery.default
+      password: splunk.discovery.default
+      collection_interval: 10s
+  status:
+    metrics:
+      - status: successful
+        strict: rabbitmq.consumer.count
+        message: rabbitmq receiver is working!
+    statements:
+      - status: failed
+        regexp: 'connect: network is unreachable'
+        message: The container cannot be reached by the Collector. Make sure they're in the same network.
+      - status: failed
+        regexp: 'connect: connection refused'
+        message: The container is refusing kafka server connections.

internal/confmapprovider/discovery/bundle/bundle.d/receivers/rabbitmq.discovery.yaml.tmpl

@@ -0,0 +1,24 @@
+{{ receiver "rabbitmq" }}:
+  enabled: true
+  rule:
+    docker_observer: type == "container" and any([name, image, command], {# matches "(?i)rabbitmq.*"}) and not (command matches "splunk.discovery")
+    host_observer: type == "hostport" and command matches "(?i)rabbitmq.*" and not (command matches "splunk.discovery")
+    k8s_observer: type == "port" and pod.name matches "(?i)rabbitmq.*"
+  config:
+    default:
+      endpoint: '`endpoint`'
+      username: {{ defaultValue }}
+      password: {{ defaultValue }}
+      collection_interval: 10s
+  status:
+    metrics:
+      - status: successful
+        strict: rabbitmq.consumer.count
+        message: rabbitmq receiver is working!
+    statements:
+      - status: failed
+        regexp: 'connect: network is unreachable'
+        message: The container cannot be reached by the Collector. Make sure they're in the same network.
+      - status: failed
+        regexp: 'connect: connection refused'
+        message: The container is refusing kafka server connections.

internal/confmapprovider/discovery/bundle/bundle_gen.go

@@ -35,6 +35,8 @@
 //go:generate discoverybundler -r -c -d ../../../../cmd/otelcol/config/collector/config.d.linux/receivers -t bundle.d/receivers/oracledb.discovery.yaml.tmpl
 //go:generate discoverybundler -r -t bundle.d/receivers/postgresql.discovery.yaml.tmpl
 //go:generate discoverybundler -r -c -d ../../../../cmd/otelcol/config/collector/config.d.linux/receivers -t bundle.d/receivers/postgresql.discovery.yaml.tmpl
+//go:generate discoverybundler -r -t bundle.d/receivers/rabbitmq.discovery.yaml.tmpl
+//go:generate discoverybundler -r -c -d ../../../../cmd/otelcol/config/collector/config.d.linux/receivers -t bundle.d/receivers/rabbitmq.discovery.yaml.tmpl
 //go:generate discoverybundler -r -t bundle.d/receivers/redis.discovery.yaml.tmpl
 //go:generate discoverybundler -r -c -d ../../../../cmd/otelcol/config/collector/config.d.linux/receivers -t bundle.d/receivers/redis.discovery.yaml.tmpl
 //go:generate discoverybundler -r -t bundle.d/receivers/smartagent-collectd-mysql.discovery.yaml.tmpl

internal/confmapprovider/discovery/bundle/bundledfs_other_test.go

@@ -33,6 +33,7 @@ func TestBundleDir(t *testing.T) {
 		"bundle.d/receivers/mysql.discovery.yaml",
 		"bundle.d/receivers/oracledb.discovery.yaml",
 		"bundle.d/receivers/postgresql.discovery.yaml",
+		"bundle.d/receivers/rabbitmq.discovery.yaml",
 		"bundle.d/receivers/redis.discovery.yaml",
 		"bundle.d/receivers/smartagent-collectd-mysql.discovery.yaml",
 		"bundle.d/receivers/smartagent-collectd-nginx.discovery.yaml",

internal/confmapprovider/discovery/bundle/bundledfs_others.go

@@ -31,6 +31,7 @@ import (
 //go:embed bundle.d/receivers/mysql.discovery.yaml
 //go:embed bundle.d/receivers/oracledb.discovery.yaml
 //go:embed bundle.d/receivers/postgresql.discovery.yaml
+//go:embed bundle.d/receivers/rabbitmq.discovery.yaml
 //go:embed bundle.d/receivers/redis.discovery.yaml
 //go:embed bundle.d/receivers/smartagent-collectd-mysql.discovery.yaml
 //go:embed bundle.d/receivers/smartagent-collectd-nginx.discovery.yaml

internal/confmapprovider/discovery/bundle/bundledfs_windows.go

@@ -31,6 +31,7 @@ import (
 //go:embed bundle.d/receivers/mysql.discovery.yaml
 //go:embed bundle.d/receivers/oracledb.discovery.yaml
 //go:embed bundle.d/receivers/postgresql.discovery.yaml
+//go:embed bundle.d/receivers/rabbitmq.discovery.yaml
 //go:embed bundle.d/receivers/redis.discovery.yaml
 //go:embed bundle.d/receivers/smartagent-postgresql.discovery.yaml
 var BundledFS embed.FS

internal/confmapprovider/discovery/bundle/bundledfs_windows_test.go

@@ -33,6 +33,7 @@ func TestBundleDir(t *testing.T) {
 		"bundle.d/receivers/mysql.discovery.yaml",
 		"bundle.d/receivers/oracledb.discovery.yaml",
 		"bundle.d/receivers/postgresql.discovery.yaml",
+		"bundle.d/receivers/rabbitmq.discovery.yaml",
 		"bundle.d/receivers/redis.discovery.yaml",
 		"bundle.d/receivers/smartagent-postgresql.discovery.yaml",
 	}, receivers)

internal/confmapprovider/discovery/bundle/components.go

@@ -37,6 +37,7 @@ var (
 		"mysql",
 		"oracledb",
 		"postgresql",
+		"rabbitmq",
 		"redis",
 		"smartagent-collectd-mysql",
 		"smartagent-collectd-nginx",
@@ -70,6 +71,7 @@ var (
 				"mysql":                 {},
 				"oracledb":              {},
 				"postgresql":            {},
+				"rabbitmq":              {},
 				"redis":                 {},
 				"smartagent-postgresql": {},
 			}