Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for mfs (0.05 sec)

  1. cmd/metrics.go

    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if ok {
    			tc.FuncName = "handler.MetricsLegacy"
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		mfs, err := gatherers.Gather()
    		if err != nil {
    			if len(mfs) == 0 {
    				writeErrorResponseJSON(r.Context(), w, toAdminAPIErr(r.Context(), err), r.URL)
    				return
    			}
    		}
    
    		contentType := expfmt.Negotiate(r.Header)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/x509metrics/server_cert_deprecations_test.go

    	return tlsServer, serverURL
    }
    
    func getSingleCounterValueFromRegistry(t *testing.T, r metrics.Gatherer, name string) int {
    	mfs, err := r.Gather()
    	if err != nil {
    		t.Logf("failed to gather local registry metrics: %v", err)
    		return -1
    	}
    
    	for _, mf := range mfs {
    		if mf.Name != nil && *mf.Name == name {
    			mfMetric := mf.GetMetric()
    			for _, m := range mfMetric {
    				if m.GetCounter() != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 25.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go

    	}
    }
    
    func getSingleCounterValueFromRegistry(t *testing.T, r metrics.Gatherer, name string) int {
    	mfs, err := r.Gather()
    	if err != nil {
    		t.Logf("failed to gather local registry metrics: %v", err)
    		return -1
    	}
    
    	for _, mf := range mfs {
    		if mf.Name != nil && *mf.Name == name {
    			mfMetric := mf.GetMetric()
    			for _, m := range mfMetric {
    				if m.GetCounter() != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  4. pilot/cmd/pilot-agent/status/server.go

    		}
    	}
    	return FmtText
    }
    
    func scrapeAndWriteAgentMetrics(registry prometheus.Gatherer, w io.Writer) error {
    	mfs, err := registry.Gather()
    	enc := expfmt.NewEncoder(w, FmtText)
    	if err != nil {
    		return err
    	}
    	for _, mf := range mfs {
    		if err := enc.Encode(mf); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 31.1K bytes
    - Viewed (1)
Back to top