Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewRegistry (0.07 sec)

  1. cmd/metrics-v3-handler.go

    }
    
    var (
    	globalMetricsV3CollectorPaths []collectorPath
    	globalMetricsV3Once           sync.Once
    )
    
    func newMetricsV3Server(auth func(h http.Handler) http.Handler) *metricsV3Server {
    	registry := prometheus.NewRegistry()
    	metricGroups := newMetricGroups(registry)
    	globalMetricsV3Once.Do(func() {
    		globalMetricsV3CollectorPaths = metricGroups.collectorPaths
    	})
    	return &metricsV3Server{
    		registry: registry,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  2. cmd/metrics-v3.go

    		collectors[mg.CollectorPath] = mg
    	}
    
    	// 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 00:55:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/metrics.go

    				[]string{"disk"}, nil),
    			prometheus.GaugeValue,
    			float64(disk.TotalSpace),
    			disk.DrivePath,
    		)
    	}
    }
    
    func metricsHandler() http.Handler {
    	registry := prometheus.NewRegistry()
    
    	logger.CriticalIf(GlobalContext, registry.Register(minioVersionInfo))
    
    	logger.CriticalIf(GlobalContext, registry.Register(newMinioCollector()))
    
    	gatherers := prometheus.Gatherers{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/bucket-replication-stats.go

    	}
    	return st.Clone()
    }
    
    // NewReplicationStats initialize in-memory replication statistics
    func NewReplicationStats(ctx context.Context, objectAPI ObjectLayer) *ReplicationStats {
    	r := metrics.NewRegistry()
    	rs := ReplicationStats{
    		Cache:           make(map[string]*BucketReplicationStats),
    		qCache:          newQueueCache(r),
    		pCache:          newProxyStatsCache(),
    		srStats:         newSRStats(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    	}
    }
    
    func metricsHTTPHandler(c prometheus.Collector, funcName string) http.Handler {
    	registry := prometheus.NewRegistry()
    
    	// Report all other metrics
    	logger.CriticalIf(GlobalContext, registry.Register(c))
    
    	// DefaultGatherers include golang metrics and process metrics.
    	gatherers := prometheus.Gatherers{
    		registry,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top