Skip to content

Commit

Permalink
Merge pull request #2007 from mmamczur/service-metrics-time
Browse files Browse the repository at this point in the history
Add log of processing time for the service metrics.
  • Loading branch information
k8s-ci-robot authored Mar 15, 2023
2 parents 3d1d8ca + 490f4ea commit dd061f5
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion pkg/servicemetrics/servicemetrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,11 @@ package servicemetrics

import (
"fmt"
"k8s.io/utils/net"
"strconv"
"time"

"k8s.io/utils/net"

"github.com/prometheus/client_golang/prometheus"
v1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/labels"
Expand Down Expand Up @@ -165,6 +166,7 @@ type serviceGCPFeaturesMetricState struct {
}

func (c *Controller) export() {
start := time.Now()
serviceLister := c.serviceInformer.GetIndexer()
allServices, err := listers.NewServiceLister(serviceLister).List(labels.Everything())
if err != nil {
Expand All @@ -175,6 +177,7 @@ func (c *Controller) export() {
l4ProtocolState, ipStackState, gcpFeaturesState := calculateMetrics(allServices)

updatePrometheusMetrics(l4ProtocolState, ipStackState, gcpFeaturesState)
klog.Infof("Exported service metrics in %v ms", time.Since(start).Microseconds())
}

func calculateMetrics(services []*v1.Service) (map[serviceL4ProtocolMetricState]int64, map[serviceIPStackMetricState]int64, map[serviceGCPFeaturesMetricState]int64) {
Expand Down

0 comments on commit dd061f5

Please sign in to comment.