Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for Dsc (0.24 sec)

  1. cmd/bucket-replication-utils.go

    				delete(userDefined, k)
    				userDefined[targetResetHeader(rcfg.Config.RoleArn)] = v
    			}
    		}
    	}
    
    	var dsc ReplicateDecision
    	if oi.DeleteMarker || !oi.VersionPurgeStatus.Empty() {
    		dsc = checkReplicateDelete(GlobalContext, oi.Bucket, ObjectToDelete{
    			ObjectV: ObjectV{
    				ObjectName: oi.Name,
    				VersionID:  oi.VersionID,
    			},
    		}, oi, ObjectOptions{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  2. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	if replStatus == replication.Replica && !mopts.isMetadataReplication() {
    		return dsc
    	}
    
    	if mopts.replicationRequest { // incoming replication request on target cluster
    		return dsc
    	}
    
    	cfg, err := getReplicationConfig(ctx, bucket)
    	if err != nil {
    		replLogOnceIf(ctx, err, bucket)
    		return dsc
    	}
    	if cfg == nil {
    		return dsc
    	}
    
    	opts := replication.ObjectOpts{
    		Name:           object,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  4. 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 o.VersionID {
    	case "":
    		o.DeleteReplication.ReplicationStatusInternal = dsc.PendingStatus()
    		o.DeleteReplication.Targets = replicationStatusesMap(o.DeleteReplication.ReplicationStatusInternal)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  6. cmd/s3-zip-handlers.go

    	popts := ObjectOptions{
    		MTime:     srcInfo.ModTime,
    		VersionID: srcInfo.VersionID,
    		EvalMetadataFn: func(oi *ObjectInfo, gerr error) (dsc ReplicateDecision, err error) {
    			oi.UserDefined[archiveTypeMetadataKey] = at
    			oi.UserDefined[archiveInfoMetadataKey] = zipInfoStr
    			return dsc, nil
    		},
    	}
    
    	// For all other modes use in-place update to update metadata on a specific version.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  7. 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 = replication.VersionPurgePending
    					object.VersionPurgeStatuses = dsc.PendingStatus()
    				} else {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  8. cmd/object-api-datatypes_gen.go

    	// string "ResetID"
    	o = append(o, 0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44)
    	o = msgp.AppendString(o, z.ResetID)
    	// string "Dsc"
    	o = append(o, 0xa3, 0x44, 0x73, 0x63)
    	o, err = z.Dsc.MarshalMsg(o)
    	if err != nil {
    		err = msgp.WrapError(err, "Dsc")
    		return
    	}
    	// string "ExistingObjResync"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 71.7K bytes
    - Viewed (0)
  9. cmd/object-api-datatypes.go

    	ReplicationState           ReplicationState
    	DeleteMarker               bool
    
    	OpType               replication.Type
    	EventType            string
    	RetryCount           uint32
    	ResetID              string
    	Dsc                  ReplicateDecision
    	ExistingObjResync    ResyncDecision
    	TargetArn            string
    	TargetStatuses       map[string]replication.StatusType
    	TargetPurgeStatuses  map[string]VersionPurgeStatusType
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  10. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
Back to top