Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for DeleteMarkerReplicationStatus (0.28 sec)

  1. cmd/api-datatypes.go

    	VersionID  string `xml:"VersionId"`
    }
    
    // ObjectToDelete carries key name for the object to delete.
    type ObjectToDelete struct {
    	ObjectV
    	// Replication status of DeleteMarker
    	DeleteMarkerReplicationStatus string `xml:"DeleteMarkerReplicationStatus"`
    	// Status of versioned delete (of object or DeleteMarker)
    	VersionPurgeStatus VersionPurgeStatusType `xml:"VersionPurgeStatus"`
    	// VersionPurgeStatuses holds the internal
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jan 03 09:28:52 GMT 2022
    - 3K bytes
    - Viewed (0)
  2. 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()
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  3. 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
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  4. cmd/erasure-metadata.go

    func (fi *FileInfo) ReplicationStatus() replication.StatusType {
    	return fi.ReplicationState.CompositeReplicationStatus()
    }
    
    // DeleteMarkerReplicationStatus returns overall replication status for this delete marker version across targets
    func (fi *FileInfo) DeleteMarkerReplicationStatus() replication.StatusType {
    	if fi.Deleted {
    		return fi.ReplicationState.CompositeReplicationStatus()
    	}
    	return replication.StatusType("")
    }
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  5. 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() != Complete {
    			if !fi.VersionPurgeStatus().Empty() || fi.DeleteMarkerReplicationStatus().Empty() {
    				updateVersion = true
    			}
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  6. 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())
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  7. cmd/bucket-handlers.go

    			}, goi, opts, gerr)
    			if dsc.ReplicateAny() {
    				if object.VersionID != "" {
    					object.VersionPurgeStatus = Pending
    					object.VersionPurgeStatuses = dsc.PendingStatus()
    				} else {
    					object.DeleteMarkerReplicationStatus = dsc.PendingStatus()
    				}
    				object.ReplicateDecisionStr = dsc.String()
    			}
    		}
    		if object.VersionID != "" && hasLockEnabled {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  8. 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() == Complete {
    			markDelete = false
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  9. 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())
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top