Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ReplicateAny (0.2 sec)

  1. cmd/object-handlers.go

    	op := replication.ObjectReplicationType
    	if srcInfo.metadataOnly {
    		op = replication.MetadataReplicationType
    	}
    	if dsc := mustReplicate(ctx, dstBucket, dstObject, srcInfo.getMustReplicateOptions(op, dstOpts)); dsc.ReplicateAny() {
    		srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    		srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    // ReplicateDecision represents replication decision for each target
    type ReplicateDecision struct {
    	targetsMap map[string]replicateTargetDecision
    }
    
    // ReplicateAny returns true if at least one target qualifies for replication
    func (d ReplicateDecision) ReplicateAny() bool {
    	for _, t := range d.targetsMap {
    		if t.Replicate {
    			return true
    		}
    	}
    	return false
    }
    
    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/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    		return
    	}
    	if dsc := mustReplicate(ctx, bucket, object, getMustReplicateOptions(metadata, "", "", replication.ObjectReplicationType, ObjectOptions{})); dsc.ReplicateAny() {
    		metadata[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    		metadata[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    			dsc = checkReplicateDelete(ctx, bucket, ObjectToDelete{
    				ObjectV: ObjectV{
    					ObjectName: object.ObjectName,
    					VersionID:  object.VersionID,
    				},
    			}, goi, opts, gerr)
    			if dsc.ReplicateAny() {
    				if object.VersionID != "" {
    					object.VersionPurgeStatus = Pending
    					object.VersionPurgeStatuses = dsc.PendingStatus()
    				} else {
    					object.DeleteMarkerReplicationStatus = dsc.PendingStatus()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    			return objInfo, gerr
    		}
    	}
    
    	if opts.EvalMetadataFn != nil {
    		dsc, err := opts.EvalMetadataFn(&goi, gerr)
    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		if dsc.ReplicateAny() {
    			opts.SetDeleteReplicationState(dsc, opts.VersionID)
    			goi.replicationDecision = opts.DeleteReplication.ReplicateDecisionStr
    		}
    	}
    
    	if opts.EvalRetentionBypassFn != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    		return roi
    	}
    	if rcfg.Config == nil || rcfg.remotes == nil {
    		return roi
    	}
    	roi = getHealReplicateObjectInfo(oi, rcfg)
    	roi.RetryCount = uint32(retryCount)
    	if !roi.Dsc.ReplicateAny() {
    		return
    	}
    	// early return if replication already done, otherwise we need to determine if this
    	// version is an existing object that needs healing.
    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