Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for ReplicationState (0.2 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils_test.go

    			}
    		}
    	}
    }
    
    var replicationStateTest = []struct {
    	name      string
    	rs        ReplicationState
    	arn       string
    	expStatus replication.StatusType
    }{
    	{ // 1. no replication status header
    		name:      "no replicated targets",
    		rs:        ReplicationState{},
    		expStatus: replication.StatusType(""),
    	},
    	{ // 2. replication status for one target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 08 20:27:40 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  4. cmd/api-datatypes.go

    	// MTime of DeleteMarker on source that needs to be propagated to replica
    	DeleteMarkerMTime DeleteMarkerMTime `xml:"-"`
    	// MinIO extensions to support delete marker replication
    	ReplicationState ReplicationState `xml:"-"`
    }
    
    // DeleteMarkerMTime is an embedded type containing time.Time for XML marshal
    type DeleteMarkerMTime struct {
    	time.Time
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:26:50 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. cmd/object-api-datatypes_gen.go

    	if err != nil {
    		err = msgp.WrapError(err, "VersionPurgeStatus")
    		return
    	}
    	// string "ReplicationState"
    	o = append(o, 0xb0, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x65)
    	o, err = z.ReplicationState.MarshalMsg(o)
    	if err != nil {
    		err = msgp.WrapError(err, "ReplicationState")
    		return
    	}
    	// string "DeleteMarker"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
Back to top