- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for gatherers (0.2 sec)
-
cmd/metrics-v3-handler.go
continue } unLocker := bmg.LockAndSetBuckets(buckets) 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. //
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 16:06:35 UTC 2024 - 7.6K bytes - Viewed (0) -
cmd/metrics-v3.go
// Helper function to register a collector and return a gatherer for it. mustRegister := func(c ...prometheus.Collector) prometheus.Gatherer { subRegistry := prometheus.NewRegistry() for _, col := range c { subRegistry.MustRegister(col) } r.MustRegister(subRegistry) return subRegistry } // Register all collectors and create gatherers for them.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/metrics.go
registry := prometheus.NewRegistry() logger.CriticalIf(GlobalContext, registry.Register(minioVersionInfo)) logger.CriticalIf(GlobalContext, registry.Register(newMinioCollector())) gatherers := prometheus.Gatherers{ prometheus.DefaultGatherer, registry, } return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/metrics-v2.go
gatherers := prometheus.Gatherers{ registry, } return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if ok { tc.FuncName = funcName tc.ResponseRecorder.LogErrBody = true } mfs, err := gatherers.Gather() if err != nil && len(mfs) == 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
pkg/monitoring/monitortest/test.go
"istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/retry" ) type MetricsTest struct { t test.Failer reg prometheus.Gatherer deltas map[metricKey]float64 } type metricKey struct { name string attrs attribute.Set } var reg = lazy.New(func() (prometheus.Gatherer, error) { // TODO: do not use a global and/or add a way to reset (https://github.com/open-telemetry/opentelemetry-go/issues/4291)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 7.2K bytes - Viewed (0) -
pkg/monitoring/monitoring.go
// Returned is an HTTP handler that can be used to read metrics from. func RegisterPrometheusExporter(reg prometheus.Registerer, gatherer prometheus.Gatherer) (http.Handler, error) { if reg == nil { reg = prometheus.DefaultRegisterer } if gatherer == nil { gatherer = prometheus.DefaultGatherer } promOpts := []otelprom.Option{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 9.5K bytes - Viewed (0) -
releasenotes/notes/istioctl-sort-events-by-creation.yaml
apiVersion: release-notes/v2 kind: feature area: istioctl releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 05 18:47:53 UTC 2023 - 155 bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultTransformerContextBuilder.java
return defaultModelBuilder.readRawModel(gaBuildingRequest, problems); } catch (ModelBuildingException e) { // gathered with problem collector } } return null; } private void loadFullReactor() { if (!fullReactorLoaded) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Feb 26 17:04:44 UTC 2024 - 8.8K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelTransformerContextBuilder.java
return defaultModelBuilder.readRawModel(gaBuildingRequest, problems); } catch (ModelBuilderException e) { // gathered with problem collector } } return null; } private void loadFullReactor() { if (!fullReactorLoaded) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 9.3K bytes - Viewed (0) -
cluster/images/etcd-version-monitor/etcd-version-monitor.go
&metrics.GaugeOpts{ Namespace: namespace, Name: "version_info", Help: "Etcd server's binary version", StabilityLevel: metrics.ALPHA, }, []string{"binary_version"}) gatherer = &monitorGatherer{ // Rewrite rules for etcd metrics that are exported by default. exported: map[string]*exportedMetric{ // etcd 3.0 metric format for total grpc requests with renamed method and service labels.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 06:50:02 UTC 2023 - 11.5K bytes - Viewed (0)