Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for tgtStatuses (0.06 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 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-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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top