Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for HandlerFor (0.15 sec)

  1. pkg/kubelet/kuberuntime/instrumented_services_test.go

    	l, err := net.Listen("tcp", "127.0.0.1:0")
    	assert.NoError(t, err)
    	defer l.Close()
    
    	prometheusURL := "http://" + l.Addr().String() + "/metrics"
    	mux := http.NewServeMux()
    	handler := compbasemetrics.HandlerFor(gather, compbasemetrics.HandlerOpts{})
    	mux.Handle("/metrics", handler)
    	server := &http.Server{
    		Addr:    l.Addr().String(),
    		Handler: mux,
    	}
    	go func() {
    		server.Serve(l)
    	}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  2. cmd/metrics-v3-handler.go

    				defer unLocker()
    			}
    			gatherers = append(gatherers, gatherer)
    		}
    	}
    
    	if len(gatherers) == 0 {
    		return notFoundHandler
    	}
    
    	return promhttp.HandlerFor(prometheus.Gatherers(gatherers), h.opts)
    }
    
    // ServeHTTP - implements http.Handler interface.
    //
    // When the `list` query parameter is provided (its value is ignored), the
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 16:06:35 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. pkg/monitoring/monitoring.go

    		return nil, err
    	}
    
    	opts := []metric.Option{metric.WithReader(prom)}
    	opts = append(opts, knownMetrics.toHistogramViews()...)
    	mp := metric.NewMeterProvider(opts...)
    	otel.SetMeterProvider(mp)
    	handler := promhttp.HandlerFor(gatherer, promhttp.HandlerOpts{})
    	return handler, nil
    }
    
    // A Metric collects numerical observations.
    type Metric interface {
    	// Increment records a value of 1 for the current measure. For Sums,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 9.5K bytes
    - Viewed (0)
  4. pkg/kubelet/server/server.go

    	}
    	s.restfulCont.Handle(cadvisorMetricsPath,
    		compbasemetrics.HandlerFor(r, compbasemetrics.HandlerOpts{ErrorHandling: compbasemetrics.ContinueOnError}),
    	)
    
    	s.addMetricsBucketMatcher("metrics/resource")
    	resourceRegistry := compbasemetrics.NewKubeRegistry()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  5. cluster/images/etcd-version-monitor/etcd-version-monitor.go

    	defer close(stopCh)
    	go getVersionPeriodically(stopCh)
    
    	// Serve our metrics on listenAddress/metricsPath.
    	klog.Infof("Listening on: %v", listenAddress)
    	http.Handle(metricsPath, metrics.HandlerFor(gatherer, metrics.HandlerOpts{}))
    	klog.Errorf("Stopped listening/serving metrics: %v", http.ListenAndServe(listenAddress, nil))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 16 06:50:02 UTC 2023
    - 11.5K bytes
    - Viewed (0)
Back to top