Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 77 for gatherers (0.2 sec)

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