Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for toServerHTTPStats (0.08 sec)

  1. cmd/metrics-v3-api.go

    //
    // This function currently ignores `opts`.
    func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	// Collect node level S3 HTTP metrics.
    	httpStats := globalHTTPStats.toServerHTTPStats(false)
    
    	// Currently we only collect S3 API related stats, so we set the "type"
    	// label to "s3".
    
    	m.Set(apiRejectedAuthTotal, float64(httpStats.TotalS3RejectedAuth), "type", "s3")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    	// Golang automatically resets to zero if this overflows
    	atomic.AddUint64(&st.s3RequestsIncoming, 1)
    }
    
    // Converts http stats into struct to be sent back to the client.
    func (st *HTTPStats) toServerHTTPStats(toLowerKeys bool) ServerHTTPStats {
    	serverStats := ServerHTTPStats{}
    	serverStats.S3RequestsIncoming = atomic.SwapUint64(&st.s3RequestsIncoming, 0)
    	serverStats.S3RequestsInQueue = atomic.LoadInt32(&st.s3RequestsInQueue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. 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 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