finish latency code

aerospike · Jan 5, 2024 · 43e5441 · 43e5441
1 parent 416625e
commit 43e5441
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/node_metrics.go b/node_metrics.go
@@ -18,9 +18,16 @@ func newLatencyBuckets(latencyColumns int, latencyShift int) *LatencyBuckets {
 }
 
 type NodeMetrics struct {
-	latency []LatencyBuckets
+	latency []*LatencyBuckets
 }
 
 func newNodeMetrics(policy *MetricsPolicy) *NodeMetrics {
-	return newLatencyBuckets(policy.latencyColumns, policy.latencyShift)
+	max := LATENCY_NONE
+	latency := make([]*LatencyBuckets, max)
+	for i := 0; i < max; i++ {
+		latency[i] = newLatencyBuckets(policy.latencyColumns, policy.latencyShift)
+	}
+	return &NodeMetrics{
+		latency: latency,
+	}
 }