mirror of
https://github.com/netbirdio/netbird.git
synced 2024-12-16 11:51:30 +01:00
70 lines
2.4 KiB
Go
70 lines
2.4 KiB
Go
package telemetry
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"go.opentelemetry.io/otel/metric"
|
|
)
|
|
|
|
// AccountManagerMetrics represents all metrics related to the AccountManager
|
|
type AccountManagerMetrics struct {
|
|
ctx context.Context
|
|
updateAccountPeersDurationMs metric.Float64Histogram
|
|
getPeerNetworkMapDurationMs metric.Float64Histogram
|
|
networkMapObjectCount metric.Int64Histogram
|
|
}
|
|
|
|
// NewAccountManagerMetrics creates an instance of AccountManagerMetrics
|
|
func NewAccountManagerMetrics(ctx context.Context, meter metric.Meter) (*AccountManagerMetrics, error) {
|
|
updateAccountPeersDurationMs, err := meter.Float64Histogram("management.account.update.account.peers.duration.ms",
|
|
metric.WithUnit("milliseconds"),
|
|
metric.WithExplicitBucketBoundaries(
|
|
0.5, 1, 2.5, 5, 10, 25, 50, 100, 250, 500, 1000, 2500, 5000, 10000, 30000,
|
|
))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
getPeerNetworkMapDurationMs, err := meter.Float64Histogram("management.account.get.peer.network.map.duration.ms",
|
|
metric.WithUnit("milliseconds"),
|
|
metric.WithExplicitBucketBoundaries(
|
|
0.1, 0.5, 1, 2.5, 5, 10, 25, 50, 100, 250, 500, 1000,
|
|
))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
networkMapObjectCount, err := meter.Int64Histogram("management.account.network.map.object.count",
|
|
metric.WithUnit("objects"),
|
|
metric.WithExplicitBucketBoundaries(
|
|
50, 100, 200, 500, 1000, 2500, 5000, 10000,
|
|
))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &AccountManagerMetrics{
|
|
ctx: ctx,
|
|
getPeerNetworkMapDurationMs: getPeerNetworkMapDurationMs,
|
|
updateAccountPeersDurationMs: updateAccountPeersDurationMs,
|
|
networkMapObjectCount: networkMapObjectCount,
|
|
}, nil
|
|
|
|
}
|
|
|
|
// CountUpdateAccountPeersDuration counts the duration of updating account peers
|
|
func (metrics *AccountManagerMetrics) CountUpdateAccountPeersDuration(duration time.Duration) {
|
|
metrics.updateAccountPeersDurationMs.Record(metrics.ctx, float64(duration.Nanoseconds())/1e6)
|
|
}
|
|
|
|
// CountGetPeerNetworkMapDuration counts the duration of getting the peer network map
|
|
func (metrics *AccountManagerMetrics) CountGetPeerNetworkMapDuration(duration time.Duration) {
|
|
metrics.getPeerNetworkMapDurationMs.Record(metrics.ctx, float64(duration.Nanoseconds())/1e6)
|
|
}
|
|
|
|
// CountNetworkMapObjects counts the number of network map objects
|
|
func (metrics *AccountManagerMetrics) CountNetworkMapObjects(count int64) {
|
|
metrics.networkMapObjectCount.Record(metrics.ctx, count)
|
|
}
|