- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for getTotal (0.36 sec)
-
cmd/bucket-replication-metrics.go
} else { atomic.AddUint64(&v.HeadFailedTotal, 1) atomic.AddUint64(&p.srProxyStats.HeadFailedTotal, 1) } case getObjectAPI: if !isErr { atomic.AddUint64(&v.GetTotal, 1) atomic.AddUint64(&p.srProxyStats.GetTotal, 1) } else { atomic.AddUint64(&v.GetFailedTotal, 1) atomic.AddUint64(&p.srProxyStats.GetFailedTotal, 1) } default: return } p.bucketStats[bucket] = v }
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/bucket-stats.go
} func (rl *ReplicationLastMinute) String() string { t := rl.LastMinute.getTotal() return fmt.Sprintf("ReplicationLastMinute sz= %d, n=%d , dur=%d", t.Size, t.N, t.Total) } func (rl *ReplicationLastMinute) getTotal() AccElem { return rl.LastMinute.getTotal() } // ReplicationLastHour keeps track of replication counts over the last hour type ReplicationLastHour struct {
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/last-minute.go
l.forwardTo(sec) winIdx := sec % 60 l.Totals[winIdx].merge(a) l.LastSec = sec } // Merge all recorded latencies of last minute into one func (l *lastMinuteLatency) getTotal() AccElem { var res AccElem sec := time.Now().Unix() l.forwardTo(sec) for _, elem := range l.Totals[:] { res.merge(elem) } return res }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jul 05 17:40:45 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/site-replication-metrics.go
if rt == nil { return madmin.TimedErrStats{} } errCounts := make(map[string]int) for k, v := range rt.ErrCounts { errCounts[k] = v } minuteTotals := rt.LastMinute.getTotal() hourTotals := rt.LastHour.getTotal() return madmin.TimedErrStats{ LastMinute: madmin.RStat{ Count: float64(minuteTotals.N), Bytes: minuteTotals.Size, }, LastHour: madmin.RStat{ Count: float64(hourTotals.N),
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_gen.go
} case "rtc": z.RmvTagTotal, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "RmvTagTotal") return } case "gc": z.GetTotal, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "GetTotal") return } case "hc": z.HeadTotal, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "HeadTotal") return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 33.3K bytes - Viewed (0) -
cmd/bucket-targets.go
avg time.Duration peak time.Duration N int64 } func (l *latencyStat) update(d time.Duration) { l.lastmin.add(d) l.N++ if d > l.peak { l.peak = d } l.curr = l.lastmin.getTotal().avg() l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N) } // epHealth struct represents health of a replication target endpoint. type epHealth struct { Endpoint string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} // total returns the total call count and latency for the last minute. func (e *lockedLastMinuteLatency) total() AccElem { e.mu.Lock() defer e.mu.Unlock() return e.lastMinuteLatency.getTotal() } func newXLStorageDiskIDCheck(storage *xlStorage, healthCheck bool) *xlStorageDiskIDCheck { xl := xlStorageDiskIDCheck{ storage: storage, health: newDiskHealthTracker(),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/json/SearchApiManager.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 02:17:23 GMT 2024 - 50.3K bytes - Viewed (0) -
cmd/metrics-v2.go
}) } } ml = append(ml, MetricV2{ Description: getClusterReplProxiedGetOperationsMD(clusterMetricNamespace), Value: float64(m.Proxied.GetTotal), }) ml = append(ml, MetricV2{ Description: getClusterReplProxiedHeadOperationsMD(clusterMetricNamespace), Value: float64(m.Proxied.HeadTotal), }) ml = append(ml, MetricV2{
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) -
maven-core/src/main/java/org/apache/maven/plugin/PluginManagerException.java
pluginArtifactId = mojoDescriptor.getPluginDescriptor().getArtifactId(); pluginVersion = mojoDescriptor.getPluginDescriptor().getVersion(); goal = mojoDescriptor.getGoal(); } protected PluginManagerException(MojoDescriptor mojoDescriptor, MavenProject project, String message) { super(message); this.project = project;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 6.1K bytes - Viewed (0)