- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for TotBuckets (0.19 sec)
-
cmd/site-replication-utils.go
if currSt != ResyncStarted { return currSt } totBuckets := len(m) var cmpCount, failCount int for _, st := range m { switch st { case ResyncCompleted: cmpCount++ case ResyncFailed: failCount++ } } if cmpCount == totBuckets { return ResyncCompleted } if cmpCount+failCount == totBuckets { return ResyncFailed } return ResyncStarted }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.9K bytes - Viewed (1) -
cmd/site-replication-utils_gen.go
if err != nil { err = msgp.WrapError(err, "BucketStatuses", za0001) return } z.BucketStatuses[za0001] = za0002 } case "tb": z.TotBuckets, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "TotBuckets") return } case "cst": err = z.TargetReplicationResyncStatus.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "TargetReplicationResyncStatus")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Nov 14 15:16:40 GMT 2022 - 7.2K bytes - Viewed (0) -
cmd/site-replication.go
now := UTCNow() s := SiteResyncStatus{ Version: siteResyncMetaVersion, Status: ResyncStarted, DeplID: dID, TotBuckets: len(buckets), BucketStatuses: make(map[string]ResyncStatusType), } for _, bi := range buckets { s.BucketStatuses[bi.Name] = ResyncPending } s.ResyncID = mustGetUUID() s.StartTime = now
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 184.1K bytes - Viewed (1) -
cmd/sts-handlers_test.go
} gotBuckets := set.NewStringSet() for _, b := range accInfo.Buckets { gotBuckets.Add(b.Name) if !(b.Access.Read && b.Access.Write) { c.Fatalf("root user should have read and write access to bucket: %v", b.Name) } } shouldHaveBuckets := set.CreateStringSet(bucket2, bucket) if !gotBuckets.Equals(shouldHaveBuckets) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0)