Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for labelFilter (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top