Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for toServerHTTPStats (0.06 sec)

  1. cmd/http-tracer_test.go

    		go func(readerID int) {
    			defer wg.Done()
    			for range opsPerGoroutine {
    				_ = httpStats.toServerHTTPStats(false)
    				_ = httpStats.totalS3Requests.Load(false)
    				_ = httpStats.currentS3Requests.Load(false)
    				time.Sleep(1 * time.Microsecond)
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	finalStats := httpStats.toServerHTTPStats(false)
    	totalRequests := 0
    	for _, v := range finalStats.TotalS3Requests.APIStats {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  2. cmd/metrics.go

    		)
    	}
    }
    
    // collects http metrics for MinIO server in Prometheus specific format
    // and sends to given channel
    func httpMetricsPrometheus(ch chan<- prometheus.Metric) {
    	httpStats := globalHTTPStats.toServerHTTPStats(true)
    
    	for api, value := range httpStats.CurrentS3Requests.APIStats {
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(s3Namespace, "requests", "current"),
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:06:31 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    		cacheInterval:    10 * time.Second,
    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		if !mg.metricsGroupOpts.bucketOnly {
    			httpStats := globalHTTPStats.toServerHTTPStats(true)
    			metrics = make([]MetricV2, 0, 3+
    				len(httpStats.CurrentS3Requests.APIStats)+
    				len(httpStats.TotalS3Requests.APIStats)+
    				len(httpStats.TotalS3Errors.APIStats)+
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
Back to top