Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for currentS3Requests (0.28 sec)

  1. cmd/http-stats.go

    	if !ok {
    		hstats = bucketHTTPAPIStats{
    			currentS3Requests: &HTTPAPIStats{},
    			totalS3Requests:   &HTTPAPIStats{},
    			totalS3Canceled:   &HTTPAPIStats{},
    			totalS34xxErrors:  &HTTPAPIStats{},
    			totalS35xxErrors:  &HTTPAPIStats{},
    		}
    	}
    
    	if w == nil { // when response recorder nil, this is an active request
    		hstats.currentS3Requests.Inc(api)
    		bh.httpStats[bucket] = hstats
    		return
    	} // else {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 06:25:13 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. cmd/metrics-v3-api.go

    	m.Set(apiRequestsWaitingTotal, float64(httpStats.S3RequestsInQueue), "type", "s3")
    	m.Set(apiRequestsIncomingTotal, float64(httpStats.S3RequestsIncoming), "type", "s3")
    
    	for name, value := range httpStats.CurrentS3Requests.APIStats {
    		m.Set(apiRequestsInFlightTotal, float64(value), "name", name, "type", "s3")
    	}
    	for name, value := range httpStats.TotalS3Requests.APIStats {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 07:41:18 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. cmd/handler-utils.go

    		if countBktStat {
    			globalBucketHTTPStats.updateHTTPStats(bucket, api, nil)
    		}
    
    		globalHTTPStats.currentS3Requests.Inc(api)
    		f.ServeHTTP(w, r)
    		globalHTTPStats.currentS3Requests.Dec(api)
    
    		tc, _ := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if tc != nil {
    			globalHTTPStats.updateStats(api, tc.ResponseRecorder)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  4. cmd/metrics.go

    // 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"),
    				"Total number of running s3 requests in current MinIO server instance",
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    	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)+
    				len(httpStats.TotalS35xxErrors.APIStats)+
    				len(httpStats.TotalS34xxErrors.APIStats))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    type ServerHTTPStats struct {
    	S3RequestsInQueue      int32              `json:"s3RequestsInQueue"`
    	S3RequestsIncoming     uint64             `json:"s3RequestsIncoming"`
    	CurrentS3Requests      ServerHTTPAPIStats `json:"currentS3Requests"`
    	TotalS3Requests        ServerHTTPAPIStats `json:"totalS3Requests"`
    	TotalS3Errors          ServerHTTPAPIStats `json:"totalS3Errors"`
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
Back to top