Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ReplicationState (0.07 sec)

  1. cmd/bucket-replication-utils.go

    		UserTags:             oi.UserTags,
    	}
    	if r.SSEC {
    		r.Checksum = oi.Checksum
    	}
    	return r
    }
    
    // ReplicationState - returns replication state using other internal replication metadata in ObjectInfo
    func (o ObjectInfo) ReplicationState() ReplicationState {
    	rs := ReplicationState{
    		ReplicationStatusInternal:  o.ReplicationStatusInternal,
    		VersionPurgeStatusInternal: o.VersionPurgeStatusInternal,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    	if len(tags) != 0 {
    		objInfo.UserTags = tags
    	}
    
    	// Add replication status to the object info
    	objInfo.ReplicationStatusInternal = fi.ReplicationState.ReplicationStatusInternal
    	objInfo.VersionPurgeStatusInternal = fi.ReplicationState.VersionPurgeStatusInternal
    	objInfo.ReplicationStatus = fi.ReplicationStatus()
    	if objInfo.ReplicationStatus.Empty() { // overlay x-amx-replication-status if present for replicas
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  3. cmd/object-api-datatypes.go

    	ReplicationStatus          replication.StatusType
    	ReplicationStatusInternal  string
    	VersionPurgeStatusInternal string
    	VersionPurgeStatus         VersionPurgeStatusType
    	ReplicationState           ReplicationState
    	DeleteMarker               bool
    
    	OpType               replication.Type
    	EventType            string
    	RetryCount           uint32
    	ResetID              string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2.go

    				ventry.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicaStatus] = []byte(fi.ReplicationState.ReplicaStatus)
    				ventry.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicaTimestamp] = []byte(fi.ReplicationState.ReplicaTimeStamp.UTC().Format(time.RFC3339Nano))
    			default:
    				ventry.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicationStatus] = []byte(fi.ReplicationState.ReplicationStatusInternal)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  5. cmd/object-api-interface.go

    		o.DeleteReplication.PurgeTargets = versionPurgeStatusesMap(o.DeleteReplication.VersionPurgeStatusInternal)
    	}
    }
    
    // PutReplicationState gets ReplicationState for PUT operation from ObjectOptions
    func (o *ObjectOptions) PutReplicationState() (r ReplicationState) {
    	rstatus, ok := o.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus]
    	if !ok {
    		return
    	}
    	r.ReplicationStatusInternal = rstatus
    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/erasure-object.go

    				DeleteMarkerMTime:     DeleteMarkerMTime{vr.ModTime},
    				ObjectName:            vr.Name,
    				ReplicationState:      vr.ReplicationState,
    			}
    		} else {
    			dobjects[i] = DeletedObject{
    				ObjectName:       vr.Name,
    				VersionID:        vr.VersionID,
    				ReplicationState: vr.ReplicationState,
    			}
    		}
    		versionsMap[objects[i].ObjectName] = v
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  7. 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)
  8. cmd/bucket-handlers.go

    			},
    			VersionPurgeStatus:            dObjects[i].VersionPurgeStatus(),
    			VersionPurgeStatuses:          dObjects[i].ReplicationState.VersionPurgeStatusInternal,
    			DeleteMarkerReplicationStatus: dObjects[i].ReplicationState.ReplicationStatusInternal,
    			ReplicateDecisionStr:          dObjects[i].ReplicationState.ReplicateDecisionStr,
    		}
    		dindex := objectsToDelete[objToDel]
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    						bucket,
    						version.Name,
    						ObjectOptions{
    							Versioned:         true,
    							VersionID:         versionID,
    							MTime:             version.ModTime,
    							DeleteReplication: version.ReplicationState,
    							SrcPoolIdx:        poolIdx,
    							DataMovement:      true,
    							DeleteMarker:      true, // make sure we create a delete marker
    							SkipRebalancing:   true, // make sure we skip the decommissioned pool
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom.go

    							// on the pool being decommissioned.
    							Versioned:          true,
    							VersionID:          versionID,
    							MTime:              version.ModTime,
    							DeleteReplication:  version.ReplicationState,
    							SrcPoolIdx:         idx,
    							DataMovement:       true,
    							DeleteMarker:       true, // make sure we create a delete marker
    							SkipDecommissioned: true, // make sure we skip the decommissioned pool
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
Back to top