- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for HandlerFor (0.15 sec)
-
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) -
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) -
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) -
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) -
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)