Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for dsc (0.02 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  3. 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)
  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 {
    	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)
  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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 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 = 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)
  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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K 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 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