Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for active_workers (0.13 sec)

  1. cmd/bucket-replication-metrics.go

    	h := metrics.NewHistogram(metrics.NewUniformSample(100))
    	r.Register("replication.active_workers", h)
    	return &ActiveWorkerStat{
    		hist: h,
    	}
    }
    
    // update curr and max workers;
    func (a *ActiveWorkerStat) update() {
    	if a == nil {
    		return
    	}
    	a.Curr = globalReplicationPool.Get().ActiveWorkers()
    	a.hist.Update(int64(a.Curr))
    	a.Avg = float32(a.hist.Mean())
    	a.Max = int(a.hist.Max())
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. cmd/bucket-stats.go

    	qs.NodeName = globalLocalNodeName
    	qs.Uptime = UTCNow().Unix() - globalBootTime.Unix()
    	grs := globalReplicationStats.Load()
    	if grs != nil {
    		qs.ActiveWorkers = grs.ActiveWorkers()
    	} else {
    		qs.ActiveWorkers = ActiveWorkerStat{}
    	}
    	qs.XferStats = make(map[RMetricName]XferStats)
    	qs.QStats = r.qCache.getBucketStats(bucket)
    	qs.TgtXferStats = make(map[string]map[RMetricName]XferStats)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. 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")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 57.5K bytes
    - Viewed (0)
  5. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  6. 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 {
    	if r == nil {
    		return ActiveWorkerStat{}
    	}
    	r.wlock.RLock()
    	defer r.wlock.RUnlock()
    	w := r.workers.get()
    	return ActiveWorkerStat{
    		Curr: w.Curr,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. cmd/metrics-v3-replication.go

    	m.Set(replicationMaxQueuedCount, float64(qt.Max.Count))
    	m.Set(replicationLastMinuteQueuedBytes, float64(qt.Curr.Bytes))
    	m.Set(replicationLastMinuteQueuedCount, float64(qt.Curr.Count))
    
    	qa := qs.ActiveWorkers
    	m.Set(replicationAverageActiveWorkers, float64(qa.Avg))
    	m.Set(replicationCurrentActiveWorkers, float64(qa.Curr))
    	m.Set(replicationMaxActiveWorkers, float64(qa.Max))
    
    	if len(qs.XferStats) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    		p.lrgworkers = p.lrgworkers[:len(p.lrgworkers)-1]
    		xioutil.SafeClose(worker)
    	}
    }
    
    // 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  10. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top