- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for tgtStatuses (0.04 seconds)
-
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},Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 12.1K bytes - Click Count (0) -
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])
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
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{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K bytes - Click Count (0)