rustfs/crates/ecstore/tests/storage_api.rs

#![allow(unused_imports)]

pub(crate) use rustfs_ecstore::api::bitrot::create_bitrot_reader;
pub(crate) use rustfs_ecstore::api::disk::{DiskAPI, DiskOption, DiskStore, STORAGE_FORMAT_FILE, endpoint::Endpoint, new_disk};
pub(crate) use rustfs_ecstore::api::erasure::Erasure;
pub(crate) use rustfs_ecstore::api::object::{GetObjectReader, ObjectInfo, ObjectOptions, PutObjReader};
pub(crate) use rustfs_ecstore::api::{error::Error, set_disk::SetDisks, storage::ECStore};
use rustfs_storage_api as storage_contracts;
#[cfg(feature = "test-util")]
pub(crate) mod metadata_lock {
    pub(crate) use super::storage_contracts::{
        BucketOperations, CompletePart, MakeBucketOptions, MultipartOperations, NamespaceLocking, ObjectIO, ObjectOperations,
    };
    pub(crate) use super::{Error, ObjectOptions, PutObjReader};
    pub(crate) use rustfs_ecstore::api::bucket::metadata_sys::{
        init_bucket_metadata_sys, test_support::isolated_store_over_temp_disks,
    };
    pub(crate) use rustfs_ecstore::api::set_disk::test_util::{PutObjectCommitBarrier, PutObjectCommitPause};
}

pub(crate) mod contract_compat {
    pub(crate) use super::storage_contracts::{
        BucketOperations as StorageBucketOperations, CompletePart, DeletedObject, HTTPRangeSpec,
        HealOperations as StorageHealOperations, ListMultipartsInfo, ListObjectVersionsInfo as StorageListObjectVersionsInfo,
        ListObjectsV2Info as StorageListObjectsV2Info, ListOperations as StorageListOperations, ListPartsInfo, MultipartInfo,
        MultipartOperations as StorageMultipartOperations, MultipartUploadResult, NamespaceLocking as StorageNamespaceLocking,
        ObjectIO as StorageObjectIO, ObjectInfoOrErr as StorageObjectInfoOrErr, ObjectOperations as StorageObjectOperations,
        ObjectToDelete, PartInfo, StorageAdminApi, WalkOptions as StorageWalkOptions,
    };

    pub(crate) use super::{DiskStore, ECStore, Error, GetObjectReader, ObjectInfo, ObjectOptions, PutObjReader, SetDisks};
}

pub(crate) mod manual_transition {
    pub(crate) use rustfs_ecstore::api::bucket::lifecycle::bucket_lifecycle_ops::{
        ManualTransitionQueueSnapshot, ManualTransitionRunOptions, ManualTransitionRunReport,
    };
    pub(crate) use rustfs_ecstore::api::bucket::lifecycle::manual_transition_job::{
        ManualTransitionJobRecord, ManualTransitionJobState,
    };
}

pub(crate) mod replication_compat {
    pub(crate) use rustfs_ecstore::api::bucket::replication::{
        BucketStats, DeletedObjectReplicationInfo, DynReplicationPool, ObjectOpts, REPLICATE_INCOMING_DELETE, ReplicateDecision,
        ReplicationConfigurationExt, ReplicationDeleteScheduleInput, ReplicationDeleteStateSource, ReplicationObjectBridge,
        ReplicationState, ReplicationStats, ReplicationTargetValidationError, ResyncStatusType,
        delete_replication_state_from_config, delete_replication_version_id, replication_statuses_map, replication_target_arns,
        should_remove_replication_target, should_schedule_delete_replication, should_use_existing_delete_replication_info,
        should_use_existing_delete_replication_source, validate_replication_config_target_arns,
    };
}

pub(crate) mod legacy_bitrot_read {
    pub(crate) use super::{DiskOption, Endpoint, STORAGE_FORMAT_FILE, create_bitrot_reader, new_disk};
}

pub(crate) mod minio_generated_read {
    pub(crate) use super::{
        DiskAPI, DiskOption, Endpoint, Erasure, GetObjectReader, ObjectInfo, ObjectOptions, create_bitrot_reader, new_disk,
    };
}

pub(crate) mod cleanup_isolation {
    pub(crate) use super::{DiskAPI, DiskOption, Endpoint, new_disk};
    pub(crate) use rustfs_ecstore::api::disk::{DeleteOptions, DiskError};
}

#[cfg(all(feature = "test-util", not(windows)))]
pub(crate) mod inline_heal_staging {
    pub(crate) use super::{DiskAPI, DiskOption, Endpoint, new_disk};
    pub(crate) use rustfs_ecstore::api::disk::{
        DeleteOptions, DiskError, LocalPublicationPause, LocalPublicationStage, ReadOptions,
    };
}

#[cfg(all(feature = "test-util", target_os = "linux"))]
pub(crate) mod fd_relative {
    pub(crate) use super::{DiskAPI, DiskOption, DiskStore, Endpoint, new_disk};
    pub(crate) use rustfs_ecstore::api::disk::{DiskError, LocalPublicationPause, LocalPublicationStage, ReadOptions};
}

pub(crate) mod pinned_erasure_fixtures {
    pub(crate) use super::storage_contracts::{BucketOperations, HTTPRangeSpec, MakeBucketOptions, ObjectIO};
    pub(crate) use super::{ECStore, Endpoint, Erasure, Error, ObjectOptions};
    pub(crate) use rustfs_ecstore::api::{
        bucket::metadata_sys::init_bucket_metadata_sys,
        erasure::BitrotReader,
        layout::{EndpointServerPools, Endpoints, PoolEndpoints},
        runtime::InstanceContext,
        storage::init_local_disks_with_instance_ctx,
    };
}