- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for measuredH (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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)