Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for VersionPurgePending (0.06 sec)

  1. cmd/data-scanner_test.go

    	/*
    		replObjInfos: objInfos with following modifications
    		version stack for obj-1
    		v1 uuid-1 modTime -4m	"VersionPurgeStatus: replication.VersionPurgePending"
    	*/
    	replObjInfos := slices.Clone(objInfos)
    	replObjInfos[4].VersionPurgeStatus = replication.VersionPurgePending
    	var replWants []ObjectInfo
    	replWants = append(replWants, replObjInfos[:3]...)
    	replWants = append(replWants, replObjInfos[4])
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    		case replication.VersionPurgeComplete:
    			completed++
    		}
    	}
    	if completed == len(ri.Targets) {
    		return replication.VersionPurgeComplete
    	}
    	return replication.VersionPurgePending
    }
    
    func (ri replicatedInfos) VersionPurgeStatusInternal() string {
    	b := new(bytes.Buffer)
    	for _, t := range ri.Targets {
    		if t.Empty() {
    			continue
    		}
    		if t.VersionPurgeStatus.Empty() {
    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-handlers.go

    					ObjectName: object.ObjectName,
    					VersionID:  object.VersionID,
    				},
    			}, goi, opts, gerr)
    			if dsc.ReplicateAny() {
    				if object.VersionID != "" {
    					object.VersionPurgeStatus = replication.VersionPurgePending
    					object.VersionPurgeStatuses = dsc.PendingStatus()
    				} else {
    					object.DeleteMarkerReplicationStatus = dsc.PendingStatus()
    				}
    				object.ReplicateDecisionStr = dsc.String()
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    			// is issued - this still needs to be replicated back to the other target
    			if !oi.VersionPurgeStatus.Empty() {
    				replicate = oi.VersionPurgeStatus == replication.VersionPurgePending || oi.VersionPurgeStatus == replication.VersionPurgeFailed
    				dsc.Set(newReplicateTargetDecision(tgtArn, replicate, sync))
    			}
    			continue
    		}
    		tgt := globalBucketTargetSys.GetRemoteTargetClient(bucket, tgtArn)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    		UserAgent:    r.UserAgent(),
    		Host:         handlers.GetSourceIP(r),
    	})
    
    	if objInfo.ReplicationStatus == replication.Pending || objInfo.VersionPurgeStatus == replication.VersionPurgePending {
    		dmVersionID := ""
    		versionID := ""
    		if objInfo.DeleteMarker {
    			dmVersionID = objInfo.VersionID
    		} else {
    			versionID = objInfo.VersionID
    		}
    		dobj := DeletedObjectReplicationInfo{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top