- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for labelFilter (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/metrics/testutil_test.go
continue } } } } } } // expectHistogramCountTotal ensures that the sum of counts of metrics matching the labelFilter is as // expected. func expectHistogramCountTotal(t *testing.T, name string, labelFilter map[string]string, wantCount int) { metrics, err := legacyregistry.DefaultGatherer.Gather() if err != nil { t.Fatalf("Failed to gather metrics: %s", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 24 04:26:43 UTC 2020 - 3.4K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/driver_focus.go
return func(s *profile.Sample) bool { for key, vals := range s.NumLabel { if labelFilter(vals, numLabelUnit(key)) { return true } } return false }, nil } return func(s *profile.Sample) bool { if vals, ok := s.NumLabel[wantKey]; ok { return labelFilter(vals, numLabelUnit(wantKey)) } return false }, nil } var rfx []*regexp.Regexp
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 22 23:33:06 UTC 2020 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
t.Errorf("Scraped metrics did not include expected metric %s", metricName) } } } } // gaugeValueMatch ensures that the value of gauge metrics matching the labelFilter is as expected. func gaugeValueMatch(name string, labelFilter map[string]string, wantValue int) error { metrics, err := legacyregistry.DefaultGatherer.Gather() if err != nil { return fmt.Errorf("failed to gather metrics: %s", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
return -1, nil } for i := range conditions { if conditions[i].Type == conditionType { return i, &conditions[i] } } return -1, nil } func (pc *PodCache) labelFilter(old, cur *v1.Pod) bool { // If labels/annotations updated, trigger proxy push labelsChanged := !maps.Equal(old.Labels, cur.Labels) // Annotations are only used in endpoints in one case, so just compare that one
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
c.queue.Push(func() error { return c.endpoints.podArrived(key.Name, key.Namespace) }) }) registerHandlers[*v1.Pod](c, c.podsClient, "Pods", c.pods.onEvent, c.pods.labelFilter) if features.EnableAmbient { c.ambientIndex = ambient.New(ambient.Options{ Client: kubeClient, SystemNamespace: options.SystemNamespace, DomainSuffix: options.DomainSuffix,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
src/vendor/golang.org/x/net/idna/idna9.0.0.go
s = string(b) } return s, err } // A labelIter allows iterating over domain name labels. type labelIter struct { orig string slice []string curStart int curEnd int i int } func (l *labelIter) reset() { l.curStart = 0 l.curEnd = 0 l.i = 0 } func (l *labelIter) done() bool { return l.curStart >= len(l.orig) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 19.2K bytes - Viewed (0) -
src/vendor/golang.org/x/net/idna/idna10.0.0.go
s = string(b) } return s, bidi, err } // A labelIter allows iterating over domain name labels. type labelIter struct { orig string slice []string curStart int curEnd int i int } func (l *labelIter) reset() { l.curStart = 0 l.curEnd = 0 l.i = 0 } func (l *labelIter) done() bool { return l.curStart >= len(l.orig) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 20.9K bytes - Viewed (0)