Skip to content

Commit b7b533f

Browse files
authored
add last handshake metric (#1)
* feat: add latest handshake metric * docs: add last handshake metric
1 parent d2356cc commit b7b533f

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ receivers:
2020
```
2121
peer.usage.rx_bytes
2222
peer.usage.tx_bytes
23+
peer.last_handshake
2324
```
2425

2526
## Attributes

metrics.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ func peerToMetrics(ts time.Time, deviceName string, peer *wgtypes.Peer) pmetric.
1919
resourceAttr := rs.Resource().Attributes()
2020
resourceAttr.PutStr("peer.device.name", deviceName)
2121
resourceAttr.PutStr("peer.name", peer.PublicKey.String())
22-
2322
ms := rs.ScopeMetrics().AppendEmpty().Metrics()
2423
appendPeerMetrics(ms, peer, pbts)
2524

@@ -29,6 +28,7 @@ func peerToMetrics(ts time.Time, deviceName string, peer *wgtypes.Peer) pmetric.
2928
func appendPeerMetrics(ms pmetric.MetricSlice, peer *wgtypes.Peer, ts pcommon.Timestamp) {
3029
gaugeI(ms, "usage.rx_bytes", "By", peer.ReceiveBytes, ts)
3130
gaugeI(ms, "usage.tx_bytes", "By", peer.TransmitBytes, ts)
31+
gaugeI(ms, "last_handshake", "s", int64(peer.LastHandshakeTime.Second()), ts)
3232
}
3333

3434
func initMetric(ms pmetric.MetricSlice, name, unit string) pmetric.Metric {

metrics_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ func assertPeerToMetrics(t *testing.T, peer *wgtypes.Peer, md pmetric.Metrics) {
3636
assert.Equal(t, rsm.ScopeMetrics().Len(), 1)
3737

3838
metrics := rsm.ScopeMetrics().At(0).Metrics()
39-
assert.Equal(t, metrics.Len(), 2)
39+
assert.Equal(t, metrics.Len(), 3)
4040
}
4141

4242
func getPeer() (*wgtypes.Peer, error) {

0 commit comments

Comments
 (0)