- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,123 for totals (0.31 sec)
-
cmd/last-minute.go
merged.LastSec = l.LastSec } else { l.forwardTo(o.LastSec) merged.LastSec = o.LastSec } for i := range merged.Totals { merged.Totals[i] = AccElem{ Total: l.Totals[i].Total + o.Totals[i].Total, N: l.Totals[i].N + o.Totals[i].N, Size: l.Totals[i].Size + o.Totals[i].Size, } } return merged } // Add a new duration data func (l *lastMinuteLatency) add(t time.Duration) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jul 05 17:40:45 UTC 2023 - 4.8K bytes - Viewed (0) -
cmd/last-minute_gen.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jul 05 21:45:49 UTC 2022 - 17.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
totals = totalChanges(existingSlices[0], desiredSet) if totals.added == 0 && totals.updated == 0 && totals.removed == 0 && apiequality.Semantic.DeepEqual(endpoints.Labels, compareLabels) && apiequality.Semantic.DeepEqual(compareAnnotations, existingSlices[0].Annotations) { return slices, totals } } // generate a new slice with the desired endpoints.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
cmd/bucket-stats.go
merged.Totals[i] = AccElem{ Total: l.Totals[i].Total + o.Totals[i].Total, N: l.Totals[i].N + o.Totals[i].N, Size: l.Totals[i].Size + o.Totals[i].Size, } } return merged } // Add a new duration data func (l *ReplicationLastHour) addsize(sz int64) { min := time.Now().Unix() / 60 l.forwardTo(min) winIdx := min % 60 l.Totals[winIdx].merge(AccElem{Total: min, Size: sz, N: 1})
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_helpers.go
} // totalsByAction includes total numbers for added and removed. type totalsByAction struct { added, updated, removed int } // add adds totals from another totalsByAction struct. func (t *totalsByAction) add(totals totalsByAction) { t.added += totals.added t.updated += totals.updated t.removed += totals.removed } // newDesiredCalc initializes and returns a new desiredCalc.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 4.7K bytes - Viewed (0) -
cmd/metrics-v3-bucket-replication.go
"Total number of bytes failed at least once to replicate in the last hour on a bucket", bucketL) bucketReplLastHrFailedCountMD = NewGaugeMD(bucketReplLastHrFailedCount, "Total number of objects which failed replication in the last hour on a bucket", bucketL) bucketReplLastMinFailedBytesMD = NewGaugeMD(bucketReplLastMinFailedBytes,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/bucket-stats_gen.go
} switch msgp.UnsafeString(field) { case "Totals": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Totals") return } if zb0002 != uint32(60) { err = msgp.ArrayError{Wanted: uint32(60), Got: zb0002} return } for za0001 := range z.Totals { err = z.Totals[za0001].DecodeMsg(dc) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 57.5K bytes - Viewed (0) -
src/cmd/go/script_test.go
if err != nil { t.Fatalf("reading counter file: %v", err) } for k, v := range counters { totals[k] += v } } return totals } func checkCounters(t *testing.T, telemetryDir string) { counters := readCounters(t, telemetryDir) if _, ok := scriptGoInvoked.Load(testing.TB(t)); ok { if !disabledOnPlatform && len(counters) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 12.2K bytes - Viewed (0) -
cmd/site-replication-metrics.go
} for k, v := range o.ErrCounts { n.ErrCounts[k] += v } return n } // SRStats has replication stats at site level type SRStats struct { // Total Replica size in bytes ReplicaSize int64 `json:"replicaSize"` // Total Replica received ReplicaCount int64 `json:"replicaCount"` M map[string]*SRStatus `json:"srStatusMap"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/erasure.go
if v.N > 0 { di.Metrics.LastMinute[k] = v.asTimedAction() } } for k, v := range info.Metrics.APICalls { di.Metrics.APICalls[k] = v } if info.Total > 0 { di.Utilization = float64(info.Used / info.Total * 100) } disksInfo[index] = di return nil }, index) } g.Wait() return disksInfo } // Get an aggregated storage info across all disks.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16K bytes - Viewed (0)