- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for mustResync (0.33 sec)
-
cmd/bucket-replication_test.go
ctx := t.Context() for i, test := range replicationConfigTests { if sync := test.rcfg.Resync(ctx, test.info, test.dsc, test.tgtStatuses); sync.mustResync() != test.expectedSync { t.Errorf("Test%d (%s): Resync got %t , want %t", i+1, test.name, sync.mustResync(), test.expectedSync) } } } var ( start = UTCNow().AddDate(0, 0, -1) replicationConfigTests2 = []struct {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 12.1K bytes - Viewed (0) -
cmd/bucket-replication.go
if roi.ExistingObjResync.mustResync() && (roi.ReplicationStatus == replication.Completed || roi.ReplicationStatus.Empty()) { queueReplicateDeletesWrapper(dv, roi.ExistingObjResync) return } return } if roi.ExistingObjResync.mustResync() { roi.OpType = replication.ExistingObjectReplicationType } switch roi.ReplicationStatus {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
targets map[string]ResyncTargetDecision } // Empty returns true if no targets with resync decision present func (r ResyncDecision) Empty() bool { return r.targets == nil } func (r ResyncDecision) mustResync() bool { for _, v := range r.targets { if v.Replicate { return true } } return false } func (r ResyncDecision) mustResyncTarget(tgtArn string) bool { if r.targets == nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26K bytes - Viewed (0)