From 86b3ef9e960d654717a2b52f6ba1698f8e63dce6 Mon Sep 17 00:00:00 2001
From: postmannen <postmannen@gmail.com>
Date: Fri, 1 Apr 2022 08:51:14 +0200
Subject: [PATCH] added metrics to process

---
 process.go   | 3 +++
 processes.go | 1 +
 requests.go  | 4 ++--
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/process.go b/process.go
index c14fb03..8ea3ccf 100644
--- a/process.go
+++ b/process.go
@@ -103,6 +103,8 @@ type process struct {
 	signatures *signatures
 	// errorKernel
 	errorKernel *errorKernel
+	// metrics
+	metrics *metrics
 }
 
 // prepareNewProcess will set the the provided values and the default
@@ -132,6 +134,7 @@ func newProcess(ctx context.Context, server *server, subject Subject, processKin
 		startup:          newStartup(server),
 		signatures:       server.signatures,
 		errorKernel:      server.errorKernel,
+		metrics:          server.metrics,
 	}
 
 	return proc
diff --git a/processes.go b/processes.go
index 25ce721..44914ed 100644
--- a/processes.go
+++ b/processes.go
@@ -49,6 +49,7 @@ func newProcesses(ctx context.Context, server *server) *processes {
 		errorKernel:   server.errorKernel,
 		configuration: server.configuration,
 		Signatures:    server.signatures,
+		metrics:       server.metrics,
 	}
 
 	// Prepare the parent context for the subscribers.
diff --git a/requests.go b/requests.go
index c734212..846a332 100644
--- a/requests.go
+++ b/requests.go
@@ -564,7 +564,7 @@ func (m methodREQOpProcessStop) handler(proc process, message Message, node stri
 			}
 
 			// Remove the prometheus label
-			proc.server.metrics.promProcessesAllRunning.Delete(prometheus.Labels{"processName": string(processName)})
+			proc.metrics.promProcessesAllRunning.Delete(prometheus.Labels{"processName": string(processName)})
 
 			txt := fmt.Sprintf("info: OpProcessStop: process stopped id: %v, method: %v on: %v", toStopProc.processID, sub, message.ToNode)
 			er := fmt.Errorf(txt)
@@ -1011,7 +1011,7 @@ func (m methodREQErrorLog) getKind() Event {
 
 // Handle the writing of error logs.
 func (m methodREQErrorLog) handler(proc process, message Message, node string) ([]byte, error) {
-	proc.server.metrics.promErrorMessagesReceivedTotal.Inc()
+	proc.metrics.promErrorMessagesReceivedTotal.Inc()
 
 	// If it was a request type message we want to check what the initial messages
 	// method, so we can use that in creating the file name to store the data.