diff --git a/rustfs/src/app/bucket_list_through.rs b/rustfs/src/app/bucket_list_through.rs index 89e6521bc..a97470f9a 100644 --- a/rustfs/src/app/bucket_list_through.rs +++ b/rustfs/src/app/bucket_list_through.rs @@ -432,10 +432,10 @@ mod tests { use crate::app::storage_api::bucket_usecase::bucket::on_demand_migration::{ FilterConfig, OnDemandMigrationConfig, PathStyle, PolicyConfig, Provider, SourceConfig, SourceCredentials, TlsConfig, }; + use crate::app::storage_api::bucket_usecase::s3::{ListObjectsV2Input, ListObjectsV2Output, S3Request, S3Response}; use crate::app::storage_api::test::StoragePutObjReader; use crate::app::storage_api::test::contract::bucket::{BucketOperations as _, MakeBucketOptions}; use crate::app::storage_api::test::contract::object::ObjectIO as _; - use s3s::{S3Request, dto::ListObjectsV2Input}; use std::time::Duration; use tokio::io::{AsyncReadExt, AsyncWriteExt}; @@ -621,7 +621,7 @@ mod tests { policy: SourceErrorPolicy, resume_source: Option<&str>, filter_prefix: Option<&str>, - ) -> (S3Result>, Vec) { + ) -> (S3Result>, Vec) { let store = shared_gating_ecstore().await; crate::app::runtime_sources::install_test_app_context(Arc::clone(&store)).await; let bucket = format!("odm-list-{}", uuid::Uuid::new_v4().simple()); @@ -842,7 +842,7 @@ mod tests { }); } - fn assert_source_policy_result(result: S3Result>, policy: SourceErrorPolicy) { + fn assert_source_policy_result(result: S3Result>, policy: SourceErrorPolicy) { match policy { SourceErrorPolicy::Propagate => { let error = result.expect_err("propagate must expose malformed pagination"); diff --git a/rustfs/src/app/storage_api.rs b/rustfs/src/app/storage_api.rs index 19548aa66..9f543ac95 100644 --- a/rustfs/src/app/storage_api.rs +++ b/rustfs/src/app/storage_api.rs @@ -29,11 +29,13 @@ pub(crate) fn EndpointServerPools( pub(crate) mod s3 { #[cfg(test)] pub(crate) use s3s::dto::{ - BucketVersioningStatus, DeleteMarkerReplication, DeleteMarkerReplicationStatus, Destination, ReplicationConfiguration, - ReplicationRule, ReplicationRuleFilter, ReplicationRuleStatus, ServerSideEncryptionByDefault, - ServerSideEncryptionConfiguration, ServerSideEncryptionRule, Tag, VersioningConfiguration, + BucketVersioningStatus, DeleteMarkerReplication, DeleteMarkerReplicationStatus, Destination, ListObjectsV2Input, + ListObjectsV2Output, ReplicationConfiguration, ReplicationRule, ReplicationRuleFilter, ReplicationRuleStatus, + ServerSideEncryptionByDefault, ServerSideEncryptionConfiguration, ServerSideEncryptionRule, Tag, VersioningConfiguration, }; pub(crate) use s3s::{S3Error, S3ErrorCode, S3Result}; + #[cfg(test)] + pub(crate) use s3s::{S3Request, S3Response}; } pub(crate) mod admin {