Skip to content

Commit

Permalink
changing ping metrics NodeID to only include the flow node identifier…
Browse files Browse the repository at this point in the history
…; Adding a new label nodeaddress to the ping metrics reported by the access node (#278)
  • Loading branch information
vishalchangrani authored and Kay-Zee committed Feb 17, 2021
1 parent 5c9c8f7 commit 2c89031
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 13 deletions.
19 changes: 10 additions & 9 deletions module/metrics/labels.go
Original file line number Diff line number Diff line change
@@ -1,15 +1,16 @@
package metrics

const (
LabelChannel = "topic"
LabelChain = "chain"
EngineLabel = "engine"
LabelResource = "resource"
LabelMessage = "message"
LabelNodeID = "nodeid"
LabelNodeRole = "noderole"
LabelNodeInfo = "nodeinfo"
LabelPriority = "priority"
LabelChannel = "topic"
LabelChain = "chain"
EngineLabel = "engine"
LabelResource = "resource"
LabelMessage = "message"
LabelNodeID = "nodeid"
LabelNodeAddress = "nodeaddress"
LabelNodeRole = "noderole"
LabelNodeInfo = "nodeinfo"
LabelPriority = "priority"
)

const (
Expand Down
9 changes: 5 additions & 4 deletions module/metrics/ping.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ func NewPingCollector() *PingCollector {
Namespace: namespaceNetwork,
Subsystem: subsystemGossip,
Help: "report whether a node is reachable",
}, []string{LabelNodeID, LabelNodeRole, LabelNodeInfo}),
}, []string{LabelNodeID, LabelNodeAddress, LabelNodeRole, LabelNodeInfo}),
}
return pc
}
Expand All @@ -34,8 +34,9 @@ func (pc *PingCollector) NodeReachable(node *flow.Identity, nodeInfo string, rtt
}

pc.reachable.With(prometheus.Labels{
LabelNodeID: node.String(),
LabelNodeRole: node.Role.String(),
LabelNodeInfo: nodeInfo}).
LabelNodeID: node.NodeID.String(),
LabelNodeAddress: node.Address,
LabelNodeRole: node.Role.String(),
LabelNodeInfo: nodeInfo}).
Set(rttValue)
}

0 comments on commit 2c89031

Please sign in to comment.