Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/metrics-v3-types.go

    	metricValues := newMetricValues(mg.descriptorMap)
    
    	var err error
    	if mg.IsBucketMetricsGroup() {
    		err = mg.bucketLoader(GlobalContext, metricValues, mg.cache, mg.buckets)
    	} else {
    		err = mg.loader(GlobalContext, metricValues, mg.cache)
    	}
    
    	// There is no way to handle errors here, so we panic the current goroutine
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  2. cmd/metrics-v3.go

    	for _, mg := range allMetricGroups {
    		if !strings.HasPrefix(string(mg.CollectorPath), clusterBasePath) {
    			mg.AddExtraLabels(
    				serverName, globalLocalNodeName,
    				// poolIndex, strconv.Itoa(globalLocalPoolIdx),
    			)
    		}
    		mg.SetCache(metricsCache)
    		if mg.IsBucketMetricsGroup() {
    			bucketMGMap[mg.CollectorPath] = mg
    		} else {
    			mgMap[mg.CollectorPath] = mg
    		}
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 16:07:23 GMT 2024
    - 10K bytes
    - Viewed (0)
  3. cmd/metrics-v3-handler.go

    		if mg, ok := matchingMG[collectorPath]; ok {
    			var commonLabels []string
    			for k := range mg.ExtraLabels {
    				commonLabels = append(commonLabels, k)
    			}
    			for _, d := range mg.Descriptors {
    				labels := slices.Clone(d.VariableLabels)
    				labels = append(labels, commonLabels...)
    				metric := metricDisplay{
    					Name:   mg.MetricFQN(d.Name),
    					Help:   d.Help,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  4. cmd/metrics-resource.go

    		Subsystem: subSys,
    		Name:      name,
    		Help:      help,
    		Type:      gaugeMetric,
    	}
    }
    
    func getResourceMetrics() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: resourceMetricsCacheInterval,
    	}
    	mg.RegisterRead(func(ctx context.Context) []MetricV2 {
    		metrics := []MetricV2{}
    
    		subSystems := []MetricSubsystem{interfaceSubsystem, memSubsystem, driveSubsystem, cpuSubsystem}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    }
    
    func getBucketTTFBMetric() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    	mg.RegisterRead(func(ctx context.Context) []MetricV2 {
    		return getHistogramMetrics(bucketHTTPRequestsDuration,
    			getBucketTTFBDistributionMD(), true)
    	})
    	return mg
    }
    
    func getS3TTFBMetric() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top