diff --git a/processes.go b/processes.go index 509e203..4f4fde9 100644 --- a/processes.go +++ b/processes.go @@ -274,18 +274,18 @@ func (s startup) subREQHello(p process) { proc.procFunc = func(ctx context.Context) error { sayHelloNodes := make(map[Node]struct{}) - promHelloNodes := prometheus.NewGauge(prometheus.GaugeOpts{ + s.metrics.promHelloNodes = prometheus.NewGauge(prometheus.GaugeOpts{ Name: "hello_nodes_total", Help: "The current number of total nodes who have said hello", }) - s.metrics.promRegistry.MustRegister(promHelloNodes) + s.metrics.promRegistry.MustRegister(s.metrics.promHelloNodes) - promHelloNodesNameVec := prometheus.NewGaugeVec(prometheus.GaugeOpts{ - Name: "hello_node_last_hello", + s.metrics.promHelloNodesNameVec = prometheus.NewGaugeVec(prometheus.GaugeOpts{ + Name: "hello_node_contact_last", Help: "Name of the nodes who have said hello", }, []string{"nodeName"}, ) - s.metrics.promRegistry.MustRegister(promHelloNodesNameVec) + s.metrics.promRegistry.MustRegister(s.metrics.promHelloNodesNameVec) for { // Receive a copy of the message sent from the method handler. @@ -304,8 +304,8 @@ func (s startup) subREQHello(p process) { sayHelloNodes[m.FromNode] = struct{}{} // update the prometheus metrics - promHelloNodes.Set(float64(len(sayHelloNodes))) - promHelloNodesNameVec.With(prometheus.Labels{"nodeName": string(m.FromNode)}).SetToCurrentTime() + s.metrics.promHelloNodes.Set(float64(len(sayHelloNodes))) + s.metrics.promHelloNodesNameVec.With(prometheus.Labels{"nodeName": string(m.FromNode)}).SetToCurrentTime() } } diff --git a/prometheus.go b/prometheus.go index 7b7f858..8b29286 100644 --- a/prometheus.go +++ b/prometheus.go @@ -21,6 +21,10 @@ type metrics struct { promTotalProcesses prometheus.Gauge // promProcessesVec *prometheus.GaugeVec + // + promHelloNodes prometheus.Gauge + // + promHelloNodesNameVec *prometheus.GaugeVec } // newMetrics will prepare and return a *metrics diff --git a/test.file b/test.file new file mode 100644 index 0000000..c2e7a8d --- /dev/null +++ b/test.file @@ -0,0 +1 @@ +some file content