Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/bucket-replication_test.go

    				},
    			},
    		},
    	},
    }
    
    var replicationConfigTests = []struct {
    	info         ObjectInfo
    	name         string
    	rcfg         replicationConfig
    	dsc          ReplicateDecision
    	tgtStatuses  map[string]replication.StatusType
    	expectedSync bool
    }{
    	{ // 1. no replication config
    		name:         "no replication config",
    		info:         ObjectInfo{Size: 100},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  2. 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)
  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/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)
  6. 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)
Back to top