- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for toServerHTTPStats (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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")
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 9.4K bytes - Click Count (0) -
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)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 11.4K bytes - Click Count (0) -
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)+
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0)