Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ReplicateDecisionStr (0.13 sec)

  1. cmd/api-datatypes.go

    	VersionPurgeStatus VersionPurgeStatusType `xml:"VersionPurgeStatus"`
    	// VersionPurgeStatuses holds the internal
    	VersionPurgeStatuses string `xml:"VersionPurgeStatuses"`
    	// ReplicateDecisionStr stringified representation of replication decision
    	ReplicateDecisionStr string `xml:"-"`
    }
    
    // createBucketLocationConfiguration container for bucket configuration request from client.
    // Used for parsing the location from the request body for Makebucket.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 3K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    func getReplicationState(rinfos replicatedInfos, prevState ReplicationState, vID string) ReplicationState {
    	rs := ReplicationState{
    		ReplicateDecisionStr: prevState.ReplicateDecisionStr,
    		ResetStatusesMap:     prevState.ResetStatusesMap,
    		ReplicaTimeStamp:     prevState.ReplicaTimeStamp,
    		ReplicaStatus:        prevState.ReplicaStatus,
    	}
    	var replStatuses, vpurgeStatuses string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "VersionPurgeStatusInternal")
    				return
    			}
    		case "ReplicateDecisionStr":
    			z.ReplicateDecisionStr, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "ReplicateDecisionStr")
    				return
    			}
    		case "Targets":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    			VersionPurgeStatuses:          dObjects[i].ReplicationState.VersionPurgeStatusInternal,
    			DeleteMarkerReplicationStatus: dObjects[i].ReplicationState.ReplicationStatusInternal,
    			ReplicateDecisionStr:          dObjects[i].ReplicationState.ReplicateDecisionStr,
    		}
    		dindex := objectsToDelete[objToDel]
    		if errs[i] == nil || isErrObjectNotFound(errs[i]) || isErrVersionNotFound(errs[i]) {
    			if replicateDeletes {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  5. 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()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    		})
    		return
    	}
    	dsc, err := parseReplicateDecision(ctx, bucket, dobj.ReplicationState.ReplicateDecisionStr)
    	if err != nil {
    		replLogOnceIf(ctx, fmt.Errorf("unable to parse replication decision parameters for bucket: %s, err: %s, decision: %s",
    			bucket, err, dobj.ReplicationState.ReplicateDecisionStr), dobj.ReplicationState.ReplicateDecisionStr)
    		sendEvent(eventArgs{
    			BucketName: bucket,
    			Object: ObjectInfo{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		if dsc.ReplicateAny() {
    			opts.SetDeleteReplicationState(dsc, opts.VersionID)
    			goi.replicationDecision = opts.DeleteReplication.ReplicateDecisionStr
    		}
    	}
    
    	if opts.EvalRetentionBypassFn != nil {
    		if err := opts.EvalRetentionBypassFn(goi, gerr); err != nil {
    			return ObjectInfo{}, err
    		}
    	}
    
    	if opts.Expiration.Expire {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
Back to top