- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for DeleteMarkerReplicationStatus (0.15 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-replication-utils.go
func (o ObjectToDelete) ReplicationState() ReplicationState { r := ReplicationState{ ReplicationStatusInternal: o.DeleteMarkerReplicationStatus, VersionPurgeStatusInternal: o.VersionPurgeStatuses, ReplicateDecisionStr: o.ReplicateDecisionStr, } r.Targets = replicationStatusesMap(o.DeleteMarkerReplicationStatus) r.PurgeTargets = versionPurgeStatusesMap(o.VersionPurgeStatuses) return r }
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/object-api-interface.go
o.DeleteReplication.ReplicaStatus = st o.DeleteReplication.ReplicaTimeStamp = UTCNow() } // DeleteMarkerReplicationStatus - returns replication status of delete marker from DeleteReplication state in ObjectOptions func (o *ObjectOptions) DeleteMarkerReplicationStatus() replication.StatusType { return o.DeleteReplication.CompositeReplicationStatus() }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.5K bytes - Click Count (0) -
cmd/xl-storage-format-v2.go
updateVersion := false if fi.VersionPurgeStatus().Empty() && (fi.DeleteMarkerReplicationStatus() == "REPLICA" || fi.DeleteMarkerReplicationStatus().Empty()) { updateVersion = fi.MarkDeleted } else { // for replication scenario if fi.Deleted && fi.VersionPurgeStatus() != replication.VersionPurgeComplete { if !fi.VersionPurgeStatus().Empty() || fi.DeleteMarkerReplicationStatus().Empty() { updateVersion = true } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 65.6K bytes - Click Count (1) -
cmd/xl-storage-free-version_test.go
Distribution: []int{1, 2, 3, 4, 5, 6, 7, 8}, Checksums: []ChecksumInfo{{ PartNumber: 1, Algorithm: HighwayHash256S, Hash: nil, }}, }, MarkDeleted: false, // DeleteMarkerReplicationStatus: "", // VersionPurgeStatus: "", NumVersions: 1, SuccessorModTime: time.Time{}, } fi.SetTierFreeVersionID(uuid.New().String())Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 7.8K bytes - Click Count (0) -
cmd/bucket-handlers.go
if dsc.ReplicateAny() { if object.VersionID != "" { object.VersionPurgeStatus = replication.VersionPurgePending object.VersionPurgeStatuses = dsc.PendingStatus() } else { object.DeleteMarkerReplicationStatus = dsc.PendingStatus() } object.ReplicateDecisionStr = dsc.String() } } if object.VersionID != "" && hasLockEnabled {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 63.9K bytes - Click Count (0) -
cmd/erasure-object.go
if opts.VersionID != "" { // case where replica version needs to be deleted on target cluster if versionFound && opts.DeleteMarkerReplicationStatus() == replication.Replica { markDelete = false } if opts.VersionPurgeStatus().Empty() && opts.DeleteMarkerReplicationStatus().Empty() { markDelete = false } if opts.VersionPurgeStatus() == replication.VersionPurgeComplete { markDelete = falseCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
cmd/bucket-replication.go
mu.Lock() rinfos.Targets = append(rinfos.Targets, tgtInfo) mu.Unlock() }(tgtClnt) } wg.Wait() replicationStatus = rinfos.ReplicationStatus() prevStatus := dobj.DeleteMarkerReplicationStatus() if dobj.VersionID != "" { prevStatus = replication.StatusType(dobj.VersionPurgeStatus()) replicationStatus = replication.StatusType(rinfos.VersionPurgeStatus()) }
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)