#pragma once #include #include #include #include #include #include #include #include namespace Poco::Util { class AbstractConfiguration; } namespace DB { struct Settings; struct S3Settings { struct ReadWriteSettings { size_t max_single_read_retries = 0; size_t min_upload_part_size = 0; size_t upload_part_size_multiply_factor = 0; size_t upload_part_size_multiply_parts_count_threshold = 0; size_t max_single_part_upload_size = 0; size_t max_connections = 0; bool check_objects_after_upload = false; size_t max_unexpected_write_error_retries = 0; ReadWriteSettings() = default; explicit ReadWriteSettings(const Settings & settings); inline bool operator==(const ReadWriteSettings & other) const { return max_single_read_retries == other.max_single_read_retries && min_upload_part_size == other.min_upload_part_size && upload_part_size_multiply_factor == other.upload_part_size_multiply_factor && upload_part_size_multiply_parts_count_threshold == other.upload_part_size_multiply_parts_count_threshold && max_single_part_upload_size == other.max_single_part_upload_size && max_connections == other.max_connections && check_objects_after_upload == other.check_objects_after_upload && max_unexpected_write_error_retries == other.max_unexpected_write_error_retries; } void updateFromSettingsIfEmpty(const Settings & settings); }; S3::AuthSettings auth_settings; ReadWriteSettings rw_settings; inline bool operator==(const S3Settings & other) const { return auth_settings == other.auth_settings && rw_settings == other.rw_settings; } }; /// Settings for the StorageS3. class StorageS3Settings { public: StorageS3Settings() = default; void loadFromConfig(const String & config_elem, const Poco::Util::AbstractConfiguration & config, const Settings & settings); S3Settings getSettings(const String & endpoint) const; private: mutable std::mutex mutex; std::map s3_settings; }; }