- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for ReplicationState (0.23 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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,Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (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 targetCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 9.3K bytes - Click Count (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 }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 3K bytes - Click Count (0) -
cmd/bucket-replication-utils_gen_test.go
} } func BenchmarkMarshalMsgReplicationState(b *testing.B) { v := ReplicationState{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgReplicationState(b *testing.B) { v := ReplicationState{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts)))
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 23K bytes - Click Count (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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.3K bytes - Click Count (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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 21.2K bytes - Click Count (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 }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
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"Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 71.7K bytes - Click Count (0) -
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]
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 63.9K bytes - Click Count (0) -
cmd/storage-datatypes_gen.go
return } z.MarkDeleted, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "MarkDeleted") return } err = z.ReplicationState.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "ReplicationState") return } if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err) return } z.Data = nil
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 151.7K bytes - Click Count (0)