Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for dsc (0.02 sec)

  1. cmd/object-handlers.go

    			dsc := mustReplicate(ctx, bucket, object, oi.getMustReplicateOptions(replication.MetadataReplicationType, opts))
    			if dsc.ReplicateAny() {
    				oi.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
    				oi.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
    			}
    			return dsc, nil
    		},
    	}
    
    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.go

    		OpType:               opType,
    		Dsc:                  dsc,
    		TargetStatuses:       tgtStatuses,
    		TargetPurgeStatuses:  purgeStatuses,
    		ReplicationTimestamp: tm,
    		SSEC:                 crypto.SSEC.IsEncrypted(oi.UserDefined),
    		UserTags:             oi.UserTags,
    	}
    	if ri.SSEC {
    		ri.Checksum = oi.Checksum
    	}
    	if dsc.Synchronous() {
    		replicateObject(ctx, ri, o)
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    // SetDeleteReplicationState sets the delete replication options.
    func (o *ObjectOptions) SetDeleteReplicationState(dsc ReplicateDecision, vID string) {
    	o.DeleteReplication = ReplicationState{
    		ReplicateDecisionStr: dsc.String(),
    	}
    	switch {
    	case o.VersionID == "":
    		o.DeleteReplication.ReplicationStatusInternal = dsc.PendingStatus()
    		o.DeleteReplication.Targets = replicationStatusesMap(o.DeleteReplication.ReplicationStatusInternal)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  4. cmd/object-multipart-handlers.go

    		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)
  5. cmd/bucket-handlers.go

    		}
    
    		if replicateDeletes {
    			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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    			versionFound = false
    		} else if !tryDel {
    			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
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top