Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for active_workers (0.19 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-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)
Back to top