@@ -627,7 +627,7 @@ func fetchWorkerAnalytics(account cfaccounts.Account, wg *sync.WaitGroup) {
627627 }
628628}
629629
630- func fetchKVAnalytics (account cfaccounts.Account , wg * sync.WaitGroup ) {
630+ func fetchKVAnalytics (account cfaccounts.Account , wg * sync.WaitGroup , deniedMetricsSet MetricsSet ) {
631631 wg .Add (1 )
632632 defer wg .Done ()
633633
@@ -652,11 +652,15 @@ func fetchKVAnalytics(account cfaccounts.Account, wg *sync.WaitGroup) {
652652 namespaceName = kv .Dimensions .NamespaceID
653653 }
654654
655- kvRequests .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName }).Set (float64 (kv .Sum .Requests ))
656- kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P50" }).Set (float64 (kv .Quantiles .LatencyMsP50 ))
657- kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P75" }).Set (float64 (kv .Quantiles .LatencyMsP75 ))
658- kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P99" }).Set (float64 (kv .Quantiles .LatencyMsP99 ))
659- kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P999" }).Set (float64 (kv .Quantiles .LatencyMsP999 ))
655+ if ! deniedMetricsSet .Has (kvRequestsMetricName ) {
656+ kvRequests .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName }).Set (float64 (kv .Sum .Requests ))
657+ }
658+ if ! deniedMetricsSet .Has (kvLatencyMetricName ) {
659+ kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P50" }).Set (float64 (kv .Quantiles .LatencyMsP50 ))
660+ kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P75" }).Set (float64 (kv .Quantiles .LatencyMsP75 ))
661+ kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P99" }).Set (float64 (kv .Quantiles .LatencyMsP99 ))
662+ kvLatency .With (prometheus.Labels {"namespace_name" : namespaceName , "action_type" : kv .Dimensions .ActionType , "account" : accountName , "quantile" : "P999" }).Set (float64 (kv .Quantiles .LatencyMsP999 ))
663+ }
660664 }
661665 }
662666}
0 commit comments