From bbc15d9b714427d1f813129617be0f49834c8aeb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Maximilian=20Pa=C3=9F?=
 <22845248+mpass99@users.noreply.github.com>
Date: Fri, 12 May 2023 16:21:07 +0100
Subject: [PATCH] Monitor Job events

and add time to Nomad event monitoring.
---
 internal/nomad/api_querier.go | 1 +
 internal/nomad/nomad.go       | 1 +
 2 files changed, 2 insertions(+)

diff --git a/internal/nomad/api_querier.go b/internal/nomad/api_querier.go
index 408258e..4f47cf6 100644
--- a/internal/nomad/api_querier.go
+++ b/internal/nomad/api_querier.go
@@ -181,6 +181,7 @@ func (nc *nomadAPIClient) EventStream(ctx context.Context) (<-chan *nomadApi.Eve
 				// As Poseidon uses no such token, the request will return a permission denied error.
 				"*",
 			},
+			nomadApi.TopicJob: {"*"},
 		},
 		0,
 		nc.queryOptions())
diff --git a/internal/nomad/nomad.go b/internal/nomad/nomad.go
index de6f568..c53cb68 100644
--- a/internal/nomad/nomad.go
+++ b/internal/nomad/nomad.go
@@ -235,6 +235,7 @@ func dumpNomadEventToInflux(event *nomadApi.Event) {
 	p.AddTag("type", event.Type)
 	p.AddTag("key", event.Key)
 	p.AddField("payload", event.Payload)
+	p.AddTag("time", time.Now().Format("03:04:05.000000000"))
 	monitoring.WriteInfluxPoint(p)
 }