- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for ReplicationState (0.07 sec)
-
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) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 9.3K bytes - Viewed (0) -
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) -
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:"-"` found bool // the object was found during deletion } // DeleteMarkerMTime is an embedded type containing time.Time for XML marshal type DeleteMarkerMTime struct { time.Time }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
cmd/storage-datatypes.go
Parts []ObjectPartInfo `msg:"parts"` // Erasure info for all objects. Erasure ErasureInfo `msg:"ei"` MarkDeleted bool `msg:"md"` // mark this version as deleted ReplicationState ReplicationState `msg:"rs"` // Internal replication state to be passed back in ObjectInfo Data []byte `msg:"d,allownil"` // optionally carries object data NumVersions int `msg:"nv"`
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 17.4K bytes - Viewed (0)