List of all items

Structs

• app::cache::config::CacheConfig
• app::cache::manager::CacheManager
• app::cache::path::PathGenerator
• app::cache::reservation::ReservationInfo
• app::cache::stats::CacheStats
• app::cache::stats::DirectoryScanner
• app::cache::verification::HashVerifier
• app::cache::verification::VerificationFailure
• app::cache::verification::VerificationReport
• app::client::CedaClient
• app::client::auth::AuthHandler
• app::client::config::ClientConfig
• app::client::download::DownloadHandler
• app::client::http::HttpHandler
• app::coordinator::Coordinator
• app::coordinator::background_tasks::BackgroundTaskManager
• app::coordinator::completion::CompletionDetector
• app::coordinator::completion::CompletionStatus
• app::coordinator::config::CoordinatorConfig
• app::coordinator::progress::ProgressAggregator
• app::coordinator::progress::ProgressMonitor
• app::coordinator::progress::RateCalculator
• app::coordinator::signals::SignalHandler
• app::coordinator::stats::DownloadStats
• app::coordinator::stats::SessionResult
• app::hash::Md5Hash
• app::manifest::streaming::FileInfoStream
• app::manifest::streaming::ManifestStreamer
• app::manifest::types::DatasetSummary
• app::manifest::types::ManifestConfig
• app::manifest::types::ManifestStats
• app::manifest::types::ManifestVersion
• app::manifest::version_manager::ManifestVersionManager
• app::models::DatasetFileInfo
• app::models::FileInfo
• app::queue::QueueHealth
• app::queue::WorkQueueBuilder
• app::queue::config::ConfigLoader
• app::queue::config::ConfigPresets
• app::queue::config::Priority
• app::queue::config::WorkQueueConfigBuilder
• app::queue::core::WorkQueue
• app::queue::state::QueueState
• app::queue::stats::PerformanceMetrics
• app::queue::stats::StatsCalculator
• app::queue::stats::StatsManager
• app::queue::stats::StatsReporter
• app::queue::types::QueueStats
• app::queue::types::WorkInfo
• app::queue::types::WorkQueueConfig
• app::worker::SystemHealth
• app::worker::WorkerSystemBuilder
• app::worker::config::ConfigPresets
• app::worker::config::WorkerConfig
• app::worker::config::WorkerConfigBuilder
• app::worker::core::DownloadWorker
• app::worker::core::DownloadWorkerBuilder
• app::worker::pool::WorkerPool
• app::worker::pool::WorkerPoolBuilder
• app::worker::stats::BackoffCalculator
• app::worker::stats::PerformanceMetrics
• app::worker::stats::SpeedCalculator
• app::worker::stats::StatsAggregator
• app::worker::stats::StatsReporter
• app::worker::types::WorkerPoolStats
• app::worker::types::WorkerProgress
• auth::credentials::AuthStatus
• cli::args::AuthArgs
• cli::args::CacheArgs
• cli::args::Cli
• cli::args::DownloadArgs
• cli::args::GlobalArgs
• cli::args::ManifestArgs
• cli::progress::ProgressConfig
• cli::progress::ProgressDisplay
• cli::startup::ManifestUpdateStatus
• cli::startup::StartupStatus
• config::AppConfig
• config::CacheConfigToml
• config::ClientConfigToml
• config::CoordinatorConfigToml
• config::LoggingConfig
• config::ManifestConfigToml
• config::WorkQueueConfigToml
• config::WorkerConfigToml
• prelude::Arc
• prelude::Path
• prelude::PathBuf

Enums

• app::cache::reservation::ReservationState
• app::cache::reservation::ReservationStatus
• app::models::QualityControlVersion
• app::queue::types::WorkStatus
• app::worker::ResourcePressure
• app::worker::pool::PoolHealthStatus
• app::worker::pool::PoolState
• app::worker::types::WorkerStatus
• cli::args::AuthAction
• cli::args::CacheAction
• cli::args::Commands
• cli::args::ManifestAction
• cli::progress::ProgressEvent
• errors::AppError
• errors::AuthError
• errors::CacheError
• errors::ConfigError
• errors::DownloadError
• errors::ManifestError
• errors::ProgressError
• errors::QueueError
• errors::WebScrapingError

Functions

• app::coordinator::signals::create_shutdown_channel
• app::coordinator::signals::wait_for_shutdown_signal
• app::manifest::analysis::collect_datasets_and_years
• app::manifest::analysis::fill_queue_from_manifest
• app::manifest::analysis::filter_manifest_files
• app::manifest::analysis::filter_manifest_stream
• app::manifest::analysis::get_selection_options
• app::manifest::utils::collect_all_files
• app::manifest::utils::validate_manifest
• app::manifest::version_manager::parse_manifest_version
• app::models::generate_file_id
• app::models::parse_manifest_line
• app::queue::utils::add_files_with_progress
• app::queue::utils::create_test_queue
• app::queue::utils::get_queue_health
• app::queue::utils::wait_for_completion
• app::worker::pool::utils::create_production_pool
• app::worker::pool::utils::create_test_pool
• app::worker::pool::utils::monitor_until_unhealthy_or_timeout
• app::worker::pool::utils::wait_for_utilization
• app::worker::utils::calculate_optimal_worker_count
• app::worker::utils::collect_statistics_over_time
• app::worker::utils::create_development_pool
• app::worker::utils::create_high_throughput_pool
• app::worker::utils::create_production_pool
• app::worker::utils::create_test_pool
• app::worker::utils::detect_resource_pressure
• app::worker::utils::generate_health_report
• app::worker::utils::recommend_worker_config
• app::worker::utils::wait_for_health_status
• auth::credentials::check_credentials
• auth::credentials::ensure_authenticated
• auth::credentials::get_auth_status
• auth::credentials::prompt_credentials
• auth::credentials::save_credentials
• auth::credentials::setup_credentials
• auth::credentials::show_auth_status
• auth::credentials::verify_credentials
• cli::commands::handle_auth
• cli::commands::handle_cache
• cli::commands::handle_download
• cli::commands::handle_manifest
• cli::startup::check_manifest_update_needed
• cli::startup::download_manifest_files
• cli::startup::download_manifest_files_legacy
• cli::startup::format_number_with_commas
• cli::startup::get_latest_remote_version
• cli::startup::get_local_manifest_version
• cli::startup::interactive_selection
• cli::startup::parse_manifest_version
• cli::startup::show_startup_status
• cli::startup::validate_startup

Type Aliases

• app::queue::QueueResult
• app::worker::Result
• app::worker::types::WorkerResult
• errors::AuthResult
• errors::CacheResult
• errors::DownloadResult
• errors::ManifestResult
• errors::QueueResult
• errors::Result

Constants

• DESCRIPTION
• NAME
• VERSION
• app::queue::priority::BACKGROUND
• app::queue::priority::HIGH
• app::queue::priority::LOW
• app::queue::priority::NORMAL
• app::queue::priority::URGENT
• constants::auth::CEDA_AUTH_BASE_URL
• constants::auth::CEDA_LOGIN_URL
• constants::auth::CSRF_TOKEN_SELECTOR
• constants::auth::ENV_FILE_PERMISSIONS
• constants::auth::MAX_USERNAME_LENGTH
• constants::auth::MIN_USERNAME_LENGTH
• constants::cache::CACHE_INDEX_FILE
• constants::cache::FAST_VERIFICATION
• constants::cache::FULL_VERIFICATION
• constants::cache::VERIFICATION_SAMPLE_RATE
• constants::ceda::BASE_URL
• constants::ceda::DATA_PATH
• constants::ceda::MANIFEST_BASE_URL
• constants::ceda::MANIFEST_DOWNLOAD_BASE_URL
• constants::ceda::MIDAS_DIRECTORY_URL
• constants::ceda::MIDAS_OPEN_BASE_URL
• constants::ceda::TEST_FILE_URL
• constants::coordinator::CLEANUP_INTERVAL
• constants::coordinator::COMPLETION_CLEANUP_FREQUENCY
• constants::coordinator::COMPLETION_LOG_FREQUENCY
• constants::coordinator::MIN_PROGRESS_RATE_THRESHOLD
• constants::coordinator::PROGRESS_LOG_INTERVAL
• constants::coordinator::PROGRESS_TIMEOUT
• constants::coordinator::RATE_CALCULATION_WINDOW
• constants::coordinator::TASK_SHUTDOWN_TIMEOUT
• constants::coordinator::TIMEOUT_CHECK_INTERVAL
• constants::env::PASSWORD
• constants::env::USERNAME
• constants::files::BACKUP_FILE_SUFFIX
• constants::files::DOWNLOAD_CHUNK_SIZE
• constants::files::MANIFEST_FILE_NAME
• constants::files::MAX_FILE_SIZE_IN_MEMORY
• constants::files::TEMP_FILE_SUFFIX
• constants::http::CONNECT_TIMEOUT
• constants::http::DEFAULT_TIMEOUT
• constants::http::HTTP2_KEEP_ALIVE_INTERVAL
• constants::http::HTTP2_KEEP_ALIVE_TIMEOUT
• constants::http::MAX_REDIRECTS
• constants::http::POOL_IDLE_TIMEOUT
• constants::http::POOL_MAX_PER_HOST
• constants::http::USER_AGENT
• constants::limits::BACKOFF_JITTER_FACTOR
• constants::limits::CIRCUIT_BREAKER_FAILURE_THRESHOLD
• constants::limits::CIRCUIT_BREAKER_SUCCESS_THRESHOLD
• constants::limits::CIRCUIT_BREAKER_TIMEOUT_SECS
• constants::limits::DEFAULT_RATE_LIMIT_RPS
• constants::limits::MAX_BACKOFF_SECS
• constants::limits::MAX_RETRIES
• constants::limits::RETRY_BASE_DELAY_MS
• constants::limits::WEB_SCRAPING_RATE_LIMIT
• constants::limits::WEB_SCRAPING_TIMEOUT_SECS
• constants::logging::DEFAULT_LOG_LEVEL
• constants::logging::LOG_FORMAT
• constants::logging::LOG_ROTATION_SIZE
• constants::logging::MAX_LOG_FILES
• constants::memory::GC_THRESHOLD
• constants::memory::MAX_MEMORY_PERCENT
• constants::memory::MMAP_BUFFER_SIZE
• constants::progress::ETA_WINDOW_SIZE_SECS
• constants::progress::MAX_UPDATE_HZ
• constants::progress::MIN_ETA_SAMPLES
• constants::progress::UPDATE_FREQUENCY_MS
• constants::selectors::CSV_FILE_SELECTOR
• constants::selectors::DATASET_LINK_SELECTOR
• constants::selectors::DIRECTORY_LINK_SELECTOR
• constants::selectors::MANIFEST_LINK_SELECTOR
• constants::selectors::MANIFEST_MD5_SELECTOR
• constants::selectors::VERSION_LINK_SELECTOR
• constants::workers::BACKOFF_JITTER_PERCENTAGE
• constants::workers::CHANNEL_BUFFER_SIZE
• constants::workers::DEFAULT_DOWNLOAD_TIMEOUT
• constants::workers::DEFAULT_PRIORITY
• constants::workers::DEFAULT_WORKER_COUNT
• constants::workers::ERROR_SLEEP_DURATION
• constants::workers::HIGH_PRIORITY
• constants::workers::LOW_PRIORITY
• constants::workers::MANIFEST_BATCH_SIZE
• constants::workers::MAX_BACKOFF_MULTIPLIER
• constants::workers::MAX_IDLE_SLEEP_MS
• constants::workers::MAX_PENDING_ITEMS
• constants::workers::MAX_RETRIES
• constants::workers::MAX_WORKER_COUNT
• constants::workers::MIN_PROGRESS_UPDATE_INTERVAL_MS
• constants::workers::PREFETCH_COUNT
• constants::workers::QUEUE_WAIT_LOG_THRESHOLD_MS
• constants::workers::RETRY_BACKOFF_MULTIPLIER
• constants::workers::RETRY_DELAY
• constants::workers::SHORT_QUEUE_WAIT_LOG_THRESHOLD_MS
• constants::workers::SPEED_CALCULATION_SAMPLES
• constants::workers::SPEED_CALCULATION_WINDOW_SECS
• constants::workers::WORKER_QUEUE_CAPACITY
• constants::workers::WORK_TIMEOUT