gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-25 21:46:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ecstore): use replication boundary types

Browse Source
This commit is contained in:
overtrue
2026-08-22 15:53:06 +08:00
parent fd08b9f008
commit 7b103b5f74
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/ecstore/src/store/rebalance.rs
+5 -2
View File
@@ -859,6 +859,9 @@ fn lifecycle_delete_all_test_failure(phase: crate::object_api::LifecycleDeleteAl
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use super::*; 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::config::storageclass::{CLASS_RRS, CLASS_STANDARD, lookup_config_for_pools_without_env};
use crate::disk::error::DiskError; use crate::disk::error::DiskError;
use crate::layout::endpoint::Endpoint; use crate::layout::endpoint::Endpoint;
@@ -1722,12 +1725,12 @@ mod tests {
let mut replication = base.clone(); let mut replication = base.clone();
replication.replication_status_internal = Some("PENDING".to_string()); 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); assert_equal_time_identity_conflict(base.clone(), replication);
let mut purge = base.clone(); let mut purge = base.clone();
purge.version_purge_status_internal = Some("PENDING".to_string()); 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); assert_equal_time_identity_conflict(base.clone(), purge);
let mut decision = base; let mut decision = base;