Prometheus

Description

These changes let the workers expose certain metrics so prometheus on the K8s cluster can collect them. Resolves #151 (closed)

Part of #102 (closed) #120 (closed)

Changes

Additions

• Workers now report their metrics through as simple HTTPServer on port 8008

Test and Review

To be filled in by the reviewers

• All of the methods are commented to expectation

• The methods are tested to satisfaction

• There are no unnecessary files present in the MR

• The continuous integration has no problems with the MR

• The MR is filled in as requested (including labels, milestones, and reviewers)

• The documentation is up-to-date

• All nullable parameters are marked as such

worker/src/main/java/nl/tudelft/ewi/auta/worker/conn/MessageRelay.java

@@ -7,7 +7,7 @@ import java.io.OutputStream;
 import java.security.GeneralSecurityException;
 
 import nl.tudelft.ewi.auta.common.jump.Jump;
-import nl.tudelft.ewi.auta.worker.config.WorkerSettings;
+import io.prometheus.client.Gauge;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -49,9 +49,9 @@ public class MessageRelay implements Runnable {
     private final ControlProcessor controlProcessor;
 
     /**
-     * The settings for this worker.
+     * The gauge for this worker.
      */
-    private final WorkerSettings settings;
+    private final Gauge busyGauge;
 
     /**
      * The public key of the server.
@@ -76,18 +76,18 @@ public class MessageRelay implements Runnable {
      * @param jump the jump protocol to use
      * @param jobRunner the job acceptor to use
      * @param controlProcessor the control processor to use
-     * @param settings the settings for the worker
+     * @param gauge the settings for the worker
      */
     public MessageRelay(final ServerConnector connector,
                         final Jump jump,
                         final JobRunnerProvider jobRunner,
                         final ControlProcessor controlProcessor,
-                        final WorkerSettings settings) {
+                        final Gauge gauge) {
         this.connector = connector;
         this.jump = jump;
         this.jobRunner = jobRunner;
         this.controlProcessor = controlProcessor;
-        this.settings = settings;
+        this.busyGauge = gauge;
     }
 
     /**
@@ -208,7 +208,7 @@ public class MessageRelay implements Runnable {
             return;
         }
 
-        this.jobRunner.get().accept(msg, replySender);
+        this.jobRunner.get().accept(msg, replySender, this.busyGauge);
     }
 
     /**