Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for tgtStatuses (0.05 sec)

  1. cmd/bucket-replication_test.go

    				},
    			},
    		},
    	},
    }
    
    var replicationConfigTests = []struct {
    	info         ObjectInfo
    	name         string
    	rcfg         replicationConfig
    	dsc          ReplicateDecision
    	tgtStatuses  map[string]replication.StatusType
    	expectedSync bool
    }{
    	{ // 1. no replication config
    		name:         "no replication config",
    		info:         ObjectInfo{Size: 100},
    		rcfg:         replicationConfig{Config: nil},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    	}
    
    	tgtStatuses := replicationStatusesMap(oi.ReplicationStatusInternal)
    	purgeStatuses := versionPurgeStatusesMap(oi.VersionPurgeStatusInternal)
    	existingObjResync := rcfg.Resync(GlobalContext, oi, dsc, tgtStatuses)
    	tm, _ := time.Parse(time.RFC3339Nano, userDefined[ReservedMetadataPrefixLower+ReplicationTimestamp])
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	return c.resync(oi, rdsc, tgtStatuses)
    }
    
    // wrapper function for testability. Returns true if a new reset is requested on
    // already replicated objects OR object qualifies for existing object replication
    // and no reset requested.
    func (c replicationConfig) resync(oi ObjectInfo, dsc ReplicateDecision, tgtStatuses map[string]replication.StatusType) (r ResyncDecision) {
    	r = ResyncDecision{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
Back to top