- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for pendingCount (0.32 sec)
-
cmd/data-usage-cache.go
PendingSize: stat.PendingSize + st.PendingSize, FailedSize: stat.FailedSize + st.FailedSize, ReplicatedSize: stat.ReplicatedSize + st.ReplicatedSize, PendingCount: stat.PendingCount + st.PendingCount, FailedCount: stat.FailedCount + st.FailedCount, ReplicatedCount: stat.ReplicatedCount + st.ReplicatedCount, } } } for i, v := range other.ObjSizes[:] {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/bucket-stats_gen.go
case "FailedSize": z.FailedSize, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "FailedSize") return } case "PendingCount": z.PendingCount, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "PendingCount") return } case "FailedCount": z.FailedCount, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "FailedCount")
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/data-usage-cache_gen.go
return } z.FailedCount, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "FailedCount") return } z.PendingCount, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "PendingCount") return } z.MissedThresholdSize, err = dc.ReadUint64() if err != nil { err = msgp.WrapError(err, "MissedThresholdSize") return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0) -
cmd/bucket-stats.go
// Pending size in bytes PendingSize int64 `json:"pendingReplicationSize"` // Failed size in bytes FailedSize int64 `json:"failedReplicationSize"` // Total number of pending operations including metadata updates PendingCount int64 `json:"pendingReplicationCount"` // Total number of failed operations including metadata updates FailedCount int64 `json:"failedReplicationCount"` } func newBucketReplicationStats() *BucketReplicationStats {
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/data-scanner.go
tgtSizeS, ok := sizeS.replTargetStats[arn] if !ok { tgtSizeS = replTargetSizeSummary{} } switch tgtStatus { case replication.Pending: tgtSizeS.pendingCount++ tgtSizeS.pendingSize += oi.Size sizeS.pendingCount++ sizeS.pendingSize += oi.Size case replication.Failed: tgtSizeS.failedSize += oi.Size tgtSizeS.failedCount++ sizeS.failedSize += oi.Size
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 47.4K bytes - Viewed (0) -
cmd/data-usage_test.go
e.ReplicationStats = &replicationAllStats{ Targets: map[string]replicationStats{ "arn": { PendingSize: 1, ReplicatedSize: 2, FailedSize: 3, FailedCount: 5, PendingCount: 6, }, }, } want.replace("abucket/dir2", "", *e) var buf bytes.Buffer err = want.serializeTo(&buf) if err != nil { t.Fatal(err) } t.Log("serialized size:", buf.Len(), "bytes")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/xl-storage.go
} if sizeS.failedCount > 0 { res["repl-failed"] = fmt.Sprintf("%d versions, %d bytes", sizeS.failedCount, sizeS.failedSize) } if sizeS.pendingCount > 0 { res["repl-pending"] = fmt.Sprintf("%d versions, %d bytes", sizeS.pendingCount, sizeS.pendingSize) } for tgt, st := range sizeS.replTargetStats { res["repl-size-"+tgt] = strconv.FormatInt(st.replicatedSize, 10)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0)