initial commit: acc-m plugin wrapper for collector

sensu-plugin/allow_list/check-allow-list.json

@@ -0,0 +1,9 @@
+[
+    {
+        "args": [
+            ""
+        ],
+        "exec": "otel-metrics.rb",
+        "skip_arguments": true
+    }
+]

sensu-plugin/bin/.gitignore

@@ -0,0 +1 @@
+otelcol-contrib

sensu-plugin/bin/config.yaml

@@ -0,0 +1,34 @@
+receivers:
+  hostmetrics:
+    collection_interval: 10s
+    scrapers:
+      cpu:
+      memory:
+      disk:
+      filesystem:
+      load:
+      network:
+      paging:
+      processes:
+
+processors:
+  batch:
+    timeout: 5s
+  resourcedetection:
+    detectors: [env,system]
+
+exporters:
+  carbon:
+    endpoint: "localhost:2003"  # The address of the Carbon/Graphite server
+    timeout: 10s
+
+service:
+  pipelines:
+    metrics:
+      receivers: [hostmetrics]
+      processors: [batch, resourcedetection]
+      exporters: [carbon]
+
+extensions:
+  health_check:
+  pprof:

sensu-plugin/bin/otel-metrics.rb

@@ -0,0 +1,47 @@
+#!/usr/bin/env ruby
+
+# This is just a simple TCP server that proxies metrics output from the
+# carbonreceiver to stdout so it can be read by a sensu metrics plugin.
+
+require 'socket'
+require 'timeout'
+
+PORT = 2003
+HOST = '0.0.0.0'
+TIMEOUT = 15
+
+# TODO: run the collector binary / check if it's running.
+
+def start_server
+  server = TCPServer.new(HOST, PORT)
+  #puts "Server started on #{HOST}:#{PORT}"
+
+  begin
+    Timeout.timeout(TIMEOUT) do
+      loop do
+        client = server.accept
+        Thread.new(client) do |client_connection|
+          handle_client(client_connection)
+        end
+      end
+    end
+  rescue Timeout::Error
+    #puts "Server timeout reached. Shutting down..."
+  ensure
+    server.close
+  end
+end
+
+def handle_client(client)
+  loop do
+    line = client.gets
+    break if line.nil? || line.chomp.empty?
+
+    puts line.chomp
+    client.puts line
+  end
+
+  client.close
+end
+
+start_server

sensu-plugin/readme.md

@@ -0,0 +1,3 @@
+## Experimental OpenTelemetry ACC-M plugin
+
+Work in progress.