Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for measuredH (0.22 sec)

  1. cmd/site-replication-metrics.go

    			return
    		}
    	}
    }
    
    func (sr *SRStats) updateMovingAvg() {
    	sr.lock.Lock()
    	defer sr.lock.Unlock()
    	for _, s := range sr.M {
    		s.XferRateLrg.measure.updateExponentialMovingAverage(time.Now())
    		s.XferRateSml.measure.updateExponentialMovingAverage(time.Now())
    	}
    }
    
    // SRMetric captures replication metrics for a deployment
    type SRMetric struct {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  2. cmd/bucket-replication-metrics.go

    		measure: rx.measure,
    		N:       rx.N + o.N,
    	}
    }
    
    func calcAvg(x, y float64, n1, n2 int64) float64 {
    	if n1+n2 == 0 {
    		return 0
    	}
    	avg := (x*float64(n1) + y*float64(n2)) / float64(n1+n2)
    	return avg
    }
    
    // Add a new transfer
    func (rx *XferStats) addSize(sz int64, t time.Duration) {
    	if rx.measure == nil {
    		rx.measure = newRateMeasurement(time.Now())
    	}
    	rx.measure.incrementBytes(uint64(sz))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  3. cmd/speedtest.go

    				totalDownloadTTFB = append(totalDownloadTTFB, throughputHighestResults[i].DownloadTTFB...)
    			}
    
    			result.PUTStats.Response = totalUploadTimes.Measure()
    			result.GETStats.Response = totalDownloadTimes.Measure()
    			result.GETStats.TTFB = totalDownloadTTFB.Measure()
    
    			result.Size = opts.objectSize
    			result.Disks = globalEndpoints.NEndpoints()
    			result.Servers = len(globalNotificationSys.peerClients) + 1
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 28 18:04:17 GMT 2024
    - 9K bytes
    - Viewed (0)
  4. cmd/bucket-replication-stats.go

    			return
    		}
    	}
    }
    
    func (r *ReplicationStats) updateMovingAvg() {
    	r.RLock()
    	for _, s := range r.Cache {
    		for _, st := range s.Stats {
    			st.XferRateLrg.measure.updateExponentialMovingAverage(time.Now())
    			st.XferRateSml.measure.updateExponentialMovingAverage(time.Now())
    		}
    	}
    	r.RUnlock()
    }
    
    // ActiveWorkers returns worker stats
    func (r *ReplicationStats) ActiveWorkers() ActiveWorkerStat {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    		return
    	}
    
    	if err := json.NewEncoder(w).Encode(aggregateHealStateResult); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    // SitePerfHandler -  measures network throughput between site replicated setups
    func (a adminAPIHandlers) SitePerfHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  6. internal/bucket/bandwidth/monitor.go

    			return true
    		}
    	}
    	return func(bucket string) bool {
    		for _, bkt := range buckets {
    			if bkt == bucket {
    				return true
    			}
    		}
    		return false
    	}
    }
    
    // Details for the measured bandwidth
    type Details struct {
    	LimitInBytesPerSecond            int64   `json:"limitInBits"`
    	CurrentBandwidthInBytesPerSecond float64 `json:"currentBandwidth"`
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
Back to top