- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ActiveWorkers (0.35 sec)
-
cmd/bucket-stats.go
type ReplQNodeStats struct { NodeName string `json:"nodeName"` Uptime int64 `json:"uptime"` ActiveWorkers ActiveWorkerStat `json:"activeWorkers"` XferStats map[RMetricName]XferStats `json:"transferSummary"` TgtXferStats map[string]map[RMetricName]XferStats `json:"tgtTransferStats"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/site-replication-metrics_gen.go
field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "ActiveWorkers": err = z.ActiveWorkers.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "ActiveWorkers") return } case "ReplicaSize": z.ReplicaSize, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "ReplicaSize")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 40.6K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
st.XferRateLrg.measure.updateExponentialMovingAverage(time.Now()) st.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } r.RUnlock() } // ActiveWorkers returns worker stats func (r *ReplicationStats) ActiveWorkers() ActiveWorkerStat { r.wlock.RLock() defer r.wlock.RUnlock() w := r.workers.get() return ActiveWorkerStat{ Curr: w.Curr, Max: w.Max, Avg: w.Avg, } }
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/bucket-stats_gen.go
} case "Uptime": z.Uptime, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Uptime") return } case "ActiveWorkers": err = z.ActiveWorkers.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "ActiveWorkers") return } case "QStats": err = z.QStats.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "QStats") return
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 57.5K bytes - Viewed (0) -
cmd/site-replication-metrics.go
} // SRMetricsSummary captures summary of replication counts across buckets on site // along with op metrics rollup. type SRMetricsSummary struct { // op metrics roll up ActiveWorkers ActiveWorkerStat `json:"activeWorkers"` // Total Replica size in bytes ReplicaSize int64 `json:"replicaSize"` // Total number of replica received ReplicaCount int64 `json:"replicaCount"` // Queued operations
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.go
bugLogIf(p.ctx, fmt.Errorf("unknown replication type: %T", oi), "unknown-replicate-type") } } } } // ActiveWorkers returns the number of active workers handling replication traffic. func (p *ReplicationPool) ActiveWorkers() int { return int(atomic.LoadInt32(&p.activeWorkers)) } // ActiveMRFWorkers returns the number of active workers handling replication failures.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/bucket-replication-metrics.go
return &ActiveWorkerStat{ hist: h, } } // update curr and max workers; func (a *ActiveWorkerStat) update() { if a == nil { return } a.Curr = globalReplicationPool.ActiveWorkers() a.hist.Update(int64(a.Curr)) a.Avg = float32(a.hist.Mean()) a.Max = int(a.hist.Max()) } func (a *ActiveWorkerStat) get() ActiveWorkerStat { w := ActiveWorkerStat{ Curr: a.Curr,
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/site-replication.go
sm.Metrics = make(map[string]madmin.SRMetric) for _, peer := range peerSMetricsList { sm.ActiveWorkers.Avg += peer.ActiveWorkers.Avg sm.ActiveWorkers.Curr += peer.ActiveWorkers.Curr if peer.ActiveWorkers.Max > sm.ActiveWorkers.Max { sm.ActiveWorkers.Max += peer.ActiveWorkers.Max } sm.Queued.Avg.Bytes += peer.Queued.Avg.Bytes sm.Queued.Avg.Count += peer.Queued.Avg.Count
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 184.1K bytes - Viewed (1) -
cmd/metrics-v2.go
maxQueueBytes.Value = qt.Max.Bytes maxQueueCount.Value = qt.Max.Count } activeWorkersCount.Value = float64(qs.ActiveWorkers.Curr) avgActiveWorkersCount.Value = float64(qs.ActiveWorkers.Avg) maxActiveWorkersCount.Value = float64(qs.ActiveWorkers.Max) if len(qs.XferStats) > 0 { tots := qs.XferStats[Total] currTransferRate.Value = tots.Curr
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0)