rustfs/crates/ecstore/src/storage_api_contracts/mod.rs

use crate::error::Error;
use crate::object_api::{GetObjectReader, ObjectInfo, ObjectOptions, PutObjReader};
use rustfs_filemeta::FileInfo;
use std::fmt::Debug;

pub(crate) mod admin {
    pub(crate) use rustfs_storage_api::{DiskSetSelector, StorageAdminApi};
}

pub(crate) mod bucket {
    pub(crate) use rustfs_storage_api::{
        BUCKET_LIFECYCLE_LOCK_OBJECT, BucketInfo, BucketOperations, BucketOptions, DeleteBucketOptions, MakeBucketOptions,
        SRBucketDeleteOp,
    };
}

pub(crate) mod error {
    pub(crate) use rustfs_storage_api::StorageErrorCode;
}

pub(crate) mod heal {
    pub(crate) use rustfs_storage_api::HealOperations;
}

pub(crate) mod internode {
    pub(crate) use rustfs_storage_api::{
        NS_SCANNER_BODY_SHA256_QUERY, NS_SCANNER_CAPABILITY_CHALLENGE_QUERY, NS_SCANNER_CYCLE_QUERY,
        NS_SCANNER_LEADER_EPOCH_QUERY, NS_SCANNER_PROTOCOL_VERSION, NS_SCANNER_PROTOCOL_VERSION_QUERY,
        NS_SCANNER_REQUEST_ID_QUERY, NS_SCANNER_SERVER_EPOCH_QUERY, NS_SCANNER_SESSION_ID_QUERY,
        NS_SCANNER_SESSION_SEQUENCE_QUERY, NsScannerCapabilityResponse, PUT_FILE_AUTH_QUERY, PUT_FILE_AUTH_TRAILER_DIGEST_LEN,
        PUT_FILE_AUTH_TRAILER_LEN, PUT_FILE_AUTH_TRAILER_MAC_LEN, PUT_FILE_AUTH_TRAILER_MAGIC, PUT_FILE_AUTH_V1,
        PUT_FILE_CAPABILITY_CHALLENGE_QUERY, PUT_FILE_CAPABILITY_QUERY, PUT_FILE_CAPABILITY_VERSION, PUT_FILE_NONCE_QUERY,
        PUT_FILE_SERVER_EPOCH_QUERY, PutFileCapabilityResponse, SCANNER_ACTIVITY_LEGACY_PROTOCOL_VERSION,
        SCANNER_ACTIVITY_PREVIOUS_PROTOCOL_VERSION, SCANNER_ACTIVITY_PROTOCOL_VERSION, WALK_DIR_BODY_SHA256_QUERY,
        WALK_DIR_STREAM_COMPLETION_QUERY, WALK_DIR_STREAM_COMPLETION_V1,
    };
}

pub(crate) mod lifecycle {
    pub use rustfs_storage_api::{ExpirationOptions, TransitionedObject};
}

pub(crate) mod list {
    pub(crate) use rustfs_storage_api::{
        ListObjectVersionsInfo as StorageListObjectVersionsInfo, ListObjectsInfo, ListObjectsV2Info as StorageListObjectsV2Info,
        ListOperations, ObjectInfoOrErr as StorageObjectInfoOrErr, VersionMarker, WalkOptions as StorageWalkOptions,
        WalkVersionsSortOrder,
    };
}

pub(crate) mod multipart {
    pub(crate) use rustfs_storage_api::{
        CompletePart, ListMultipartsInfo, ListPartsInfo, MultipartInfo, MultipartOperations, MultipartUploadResult, PartInfo,
    };
}

pub(crate) mod namespace {
    pub(crate) use rustfs_storage_api::NamespaceLocking;
}

pub(crate) mod object {
    use super::{Debug, Error, FileInfo, GetObjectReader, ObjectInfo, ObjectOptions, PutObjReader};
    use crate::storage_api_contracts::range::HTTPRangeSpec;
    pub(crate) use rustfs_storage_api::{
        DeleteAccounting, DeletedObject, HTTPPreconditions, ObjectIO, ObjectLockDeleteOptions, ObjectLockRetentionOptions,
        ObjectOperations, ObjectPreconditionError, ObjectPreconditionPart, ObjectPreconditionState, ObjectToDelete,
    };

    pub(crate) trait EcstoreObjectIO:
        ObjectIO<
            Error = Error,
            RangeSpec = HTTPRangeSpec,
            HeaderMap = http::HeaderMap,
            ObjectOptions = ObjectOptions,
            ObjectInfo = ObjectInfo,
            GetObjectReader = GetObjectReader,
            PutObjectReader = PutObjReader,
        > + Send
        + Sync
        + Debug
        + 'static
    {
    }

    impl<T> EcstoreObjectIO for T where
        T: ObjectIO<
                Error = Error,
                RangeSpec = HTTPRangeSpec,
                HeaderMap = http::HeaderMap,
                ObjectOptions = ObjectOptions,
                ObjectInfo = ObjectInfo,
                GetObjectReader = GetObjectReader,
                PutObjectReader = PutObjReader,
            > + Send
            + Sync
            + Debug
            + 'static
    {
    }

    pub(crate) trait EcstoreObjectOperations:
        ObjectOperations<
            Error = Error,
            ObjectInfo = ObjectInfo,
            ObjectOptions = ObjectOptions,
            FileInfo = FileInfo,
            ObjectToDelete = ObjectToDelete,
            DeletedObject = DeletedObject,
        > + Send
        + Sync
        + Debug
    {
    }

    impl<T> EcstoreObjectOperations for T where
        T: ObjectOperations<
                Error = Error,
                ObjectInfo = ObjectInfo,
                ObjectOptions = ObjectOptions,
                FileInfo = FileInfo,
                ObjectToDelete = ObjectToDelete,
                DeletedObject = DeletedObject,
            > + Send
            + Sync
            + Debug
    {
    }
}

pub(crate) mod range {
    pub(crate) use rustfs_storage_api::{HTTPRangeError, HTTPRangeSpec};
}

pub(crate) mod topology {
    pub(crate) use rustfs_storage_api::{
        CapabilityStatus, DiskCapabilities, TopologyCapabilities, TopologyDisk, TopologyLabels, TopologyPool, TopologySet,
        TopologySnapshot,
    };

    #[cfg(test)]
    pub(crate) use rustfs_storage_api::CapabilityState;
}