Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for mustResync (0.09 sec)

  1. cmd/bucket-replication_test.go

    	ctx := context.Background()
    	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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
Back to top