From 7b103b5f74ec845000e8dc792b98cca27669135a Mon Sep 17 00:00:00 2001 From: overtrue Date: Sat, 22 Aug 2026 15:53:06 +0800 Subject: [PATCH] test(ecstore): use replication boundary types --- crates/ecstore/src/store/rebalance.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/crates/ecstore/src/store/rebalance.rs b/crates/ecstore/src/store/rebalance.rs index 05dcaf37e..62a0aa260 100644 --- a/crates/ecstore/src/store/rebalance.rs +++ b/crates/ecstore/src/store/rebalance.rs @@ -859,6 +859,9 @@ fn lifecycle_delete_all_test_failure(phase: crate::object_api::LifecycleDeleteAl #[cfg(test)] mod tests { use super::*; + use crate::bucket::replication::{ + ReplicationStatusType, VersionPurgeStatusType, replication_status_to_filemeta, version_purge_status_to_filemeta, + }; use crate::config::storageclass::{CLASS_RRS, CLASS_STANDARD, lookup_config_for_pools_without_env}; use crate::disk::error::DiskError; use crate::layout::endpoint::Endpoint; @@ -1722,12 +1725,12 @@ mod tests { let mut replication = base.clone(); replication.replication_status_internal = Some("PENDING".to_string()); - replication.replication_status = rustfs_filemeta::ReplicationStatusType::Pending; + replication.replication_status = replication_status_to_filemeta(ReplicationStatusType::Pending); assert_equal_time_identity_conflict(base.clone(), replication); let mut purge = base.clone(); purge.version_purge_status_internal = Some("PENDING".to_string()); - purge.version_purge_status = rustfs_filemeta::VersionPurgeStatusType::Pending; + purge.version_purge_status = version_purge_status_to_filemeta(VersionPurgeStatusType::Pending); assert_equal_time_identity_conflict(base.clone(), purge); let mut decision = base;