diff --git a/cmd/bucket-replication-utils.go b/cmd/bucket-replication-utils.go index 48816a4aa..22fac907b 100644 --- a/cmd/bucket-replication-utils.go +++ b/cmd/bucket-replication-utils.go @@ -31,6 +31,7 @@ import ( "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/bucket/replication" + "github.com/minio/minio/internal/crypto" xhttp "github.com/minio/minio/internal/http" ) @@ -539,6 +540,7 @@ func getHealReplicateObjectInfo(oi ObjectInfo, rcfg replicationConfig) Replicate ActualSize: asz, Bucket: oi.Bucket, VersionID: oi.VersionID, + ETag: oi.ETag, ModTime: oi.ModTime, ReplicationStatus: oi.ReplicationStatus, ReplicationStatusInternal: oi.ReplicationStatusInternal, @@ -553,6 +555,8 @@ func getHealReplicateObjectInfo(oi ObjectInfo, rcfg replicationConfig) Replicate TargetStatuses: tgtStatuses, TargetPurgeStatuses: purgeStatuses, ReplicationTimestamp: tm, + SSEC: crypto.SSEC.IsEncrypted(oi.UserDefined), + UserTags: oi.UserTags, } } diff --git a/cmd/bucket-replication.go b/cmd/bucket-replication.go index bd3a34cf5..10522d0a9 100644 --- a/cmd/bucket-replication.go +++ b/cmd/bucket-replication.go @@ -2274,6 +2274,7 @@ func scheduleReplication(ctx context.Context, oi ObjectInfo, o ObjectLayer, dsc ActualSize: asz, Bucket: oi.Bucket, VersionID: oi.VersionID, + ETag: oi.ETag, ModTime: oi.ModTime, ReplicationStatus: oi.ReplicationStatus, ReplicationStatusInternal: oi.ReplicationStatusInternal, @@ -2287,6 +2288,8 @@ func scheduleReplication(ctx context.Context, oi ObjectInfo, o ObjectLayer, dsc TargetStatuses: tgtStatuses, TargetPurgeStatuses: purgeStatuses, ReplicationTimestamp: tm, + SSEC: crypto.SSEC.IsEncrypted(oi.UserDefined), + UserTags: oi.UserTags, } if dsc.Synchronous() { diff --git a/cmd/object-api-datatypes.go b/cmd/object-api-datatypes.go index b8fedf71a..52cb327f2 100644 --- a/cmd/object-api-datatypes.go +++ b/cmd/object-api-datatypes.go @@ -311,6 +311,7 @@ type ReplicateObjectInfo struct { Name string Bucket string VersionID string + ETag string Size int64 ActualSize int64 ModTime time.Time