List of all items
Structs
- adaptive_ratelimit::AdaptiveRateLimitConfig
- adaptive_ratelimit::AdaptiveRateLimiter
- adaptive_ratelimit::GlobalRateLimitStats
- adaptive_ratelimit::PeerRateLimitStats
- adaptive_retry::AdaptiveRetryPolicy
- adaptive_retry::FailurePatterns
- alerting::Alert
- alerting::AlertManager
- alerting::ThresholdConfig
- analytics::AnalyticsCollector
- analytics::AnalyticsConfig
- analytics::ContentAccess
- analytics::ContentAnalytics
- analytics::ContentEarning
- analytics::DashboardAnalytics
- analytics::EarningAnalytics
- analytics::HistoricalData
- analytics::PerformanceAnalytics
- analytics::StorageAnalytics
- analytics::TimeSeriesPoint
- analytics::TransferAnalytics
- anomaly::Anomaly
- anomaly::AnomalyDetector
- anomaly::AnomalyStats
- anomaly::BehaviorSample
- anomaly::DetectionConfig
- auto_repair::ChunkRepairConfig
- auto_repair::ChunkRepairRequest
- auto_repair::ChunkRepairStats
- auto_repair::ChunkRepairStrategy
- backup::BackupConfig
- backup::BackupContentEntry
- backup::BackupManager
- backup::BackupManifest
- backup::BackupProgress
- backup::BackupResult
- backup::RestoreResult
- backup::RetentionPolicy
- bandwidth_estimation::BandwidthEstimator
- bandwidth_estimation::BandwidthStats
- bandwidth_estimation::EstimatorConfig
- batch::BatchConfig
- batch::BatchIterator
- batch::BatchProcessor
- batch::BatchResult
- cache::CacheStats
- cache::SizedCache
- cache::TieredCache
- cache::TtlCache
- cache_admission::SLRU
- cache_admission::TinyLFU
- cache_invalidation::BatchInvalidation
- cache_invalidation::InvalidationEvent
- cache_invalidation::InvalidationNotifier
- cache_invalidation::InvalidationReceiver
- cache_invalidation::InvalidationStats
- cache_warming::CacheWarmer
- cache_warming::WarmingCandidate
- cache_warming::WarmingConfig
- cache_warming::WarmingStats
- checkpoint::CheckpointConfig
- checkpoint::CheckpointManager
- checkpoint::CheckpointMetadata
- chunk_encryption::ChunkDecryptor
- chunk_encryption::ChunkEncryptor
- chunk_encryption::EncryptedChunk
- circuit_breaker::CircuitBreaker
- circuit_breaker::CircuitBreakerConfig
- compression::CompressionStats
- compression::Compressor
- config::CoordinatorSettings
- config::NetworkSettings
- config::NodeSettings
- config::NodeSettingsBuilder
- config::PerformanceSettings
- config::StorageSettings
- connection_multiplexing::ConnectionPool
- connection_multiplexing::PoolConfig
- connection_multiplexing::PoolStats
- content::ContentManager
- content::ContentManagerStats
- content_aware_cache::CacheContentMetrics
- content_aware_cache::ContentAwareCache
- content_aware_cache::ContentCacheStats
- content_router::ContentRouter
- content_router::PeerContentLocation
- content_router::RoutingStats
- custom_exporters::InfluxDBExporter
- custom_exporters::StatsDExporter
- dashboard::DashboardData
- dashboard::DataPoint
- dashboard::PerformanceSnapshot
- dashboard::TimeSeries
- dedup::ChunkRef
- dedup::ChunkReference
- dedup::ContentDedupInfo
- dedup::DedupConfig
- dedup::DedupEntry
- dedup::DedupStats
- dedup::DedupStore
- dedup::EnhancedChunkRef
- dedup::GcResult
- dedup::IntegrityCheckResult
- dedup::ReferenceEntry
- dedup::RemovalImpact
- degradation::DegradationActions
- degradation::DegradationManager
- degradation::ResourcePressure
- events::AsyncEventBus
- events::Event
- events::EventBatch
- events::EventBus
- events::EventFilter
- events::EventReplay
- events::EventStats
- events::EventStore
- expiration::ContentEntry
- expiration::ExpirationManager
- expiration::ExpirationStats
- forecasting::CapacityForecast
- forecasting::Forecaster
- gc::ContentGcResult
- gc::GarbageCollectionConfig
- gc::GarbageCollector
- gc::GcStats
- geo_selection::GeoConfig
- geo_selection::GeoLocation
- geo_selection::GeoPeer
- geo_selection::GeoSelector
- geo_selection::GeoStats
- health::HealthCheckResult
- health::HealthChecker
- health::HealthReport
- http_pool::HttpClientPool
- http_pool::HttpConfig
- integrity::ContentManifest
- integrity::ContentVerifier
- integrity::IntegrityRepairResult
- integrity::IntegrityRepairer
- integrity::ManifestBuilder
- integrity::RepairStats
- lifecycle::ContentEvent
- lifecycle::EventHistoryEntry
- lifecycle::LifecycleEventManager
- lifecycle::WebhookConfig
- logging::LogConfig
- logging::Logger
- metrics::Counter
- metrics::Gauge
- metrics::Histogram
- metrics::MetricMetadata
- metrics::MetricsRegistry
- metrics_exporter::CommonMetrics
- metrics_exporter::MetricsBatch
- metrics_exporter::MetricsExporter
- network_diag::NetworkMonitor
- network_diag::NetworkStats
- node::ContentNode
- node::NodeConfig
- node::PinnedContent
- orchestrator::OrchestratorConfig
- orchestrator::OrchestratorStats
- orchestrator::RequestOrchestrator
- orchestrator::RetrievalResult
- partial_chunk::ByteRange
- partial_chunk::ChunkRange
- partial_chunk::PartialResponse
- partial_chunk::RangeHandler
- partial_chunk::RangeRequest
- peer_selection::PeerCandidate
- peer_selection::PeerSelectionStats
- peer_selection::PeerSelector
- peer_selection::SelectionWeights
- pinning::ContentMetrics
- pinning::OptimizerStats
- pinning::PinningConfig
- pinning::PinningOptimizer
- pinning::ScoreComponents
- pinning::ScoredContent
- popularity::ContentPopularity
- popularity::PopularityConfig
- popularity::PopularityScore
- popularity::PopularityStats
- popularity::PopularityTracker
- prefetch::CachedChunk
- prefetch::ChunkPrefetcher
- prefetch::PrefetchConfig
- prefetch::PrefetchHint
- prefetch::PrefetchStats
- prefetch::PrefetcherBuilder
- priority_eviction::ContentPriority
- priority_eviction::EvictionConfig
- priority_eviction::EvictionStats
- priority_eviction::PriorityEvictor
- profiler::OperationStats
- profiler::ProfileScope
- profiler::Profiler
- proof_submit::ProofSubmitConfig
- proof_submit::ProofSubmitter
- proof_submit::QueuedProof
- proof_submit::SubmitResult
- proof_submit::SubmitStats
- qos::QosConfig
- qos::QosManager
- qos::RequestInfo
- qos::SlaMetrics
- quic_transport::IncomingConnection
- quic_transport::PoolStats
- quic_transport::QuicConfig
- quic_transport::QuicConfigBuilder
- quic_transport::QuicConnection
- quic_transport::QuicConnectionPool
- quic_transport::QuicEndpoint
- quic_transport::QuicRecvStream
- quic_transport::QuicSendStream
- quic_transport::QuicStats
- quic_transport::QuicStream
- ratelimit::BandwidthLimiter
- ratelimit::BandwidthStats
- ratelimit::PeerRateLimiter
- ratelimit::RateLimitConfig
- reputation::PeerReputation
- reputation::ReputationConfig
- reputation::ReputationStats
- reputation::ReputationTracker
- request_pipeline::PipelineConfig
- request_pipeline::PipelineRequest
- request_pipeline::PipelineResponse
- request_pipeline::PipelineStats
- request_pipeline::RequestPipeline
- resource_mgmt::MonitoringConfig
- resource_mgmt::MonitoringHandle
- resource_mgmt::ResourceLimits
- resource_mgmt::ResourceMonitor
- resource_mgmt::ResourceStats
- storage::ChunkMetadata
- storage::ChunkStorage
- storage::PinnedContentInfo
- storage::RepairResult
- storage::StorageHealth
- storage::StorageHealthMonitor
- storage::StorageHealthPrediction
- storage::StorageHealthReport
- storage::StorageStats
- storage_health::HealthConfig
- storage_health::PredictiveHealthReport
- storage_health::PredictiveStorageMonitor
- streaming::ChunkWriter
- streaming::ContentStream
- streaming::StreamConfig
- streaming_verification::MerkleVerifier
- streaming_verification::StreamingVerifier
- streaming_verification::VerificationCheckpoint
- streaming_verification::VerificationProgress
- streaming_verification::VerificationResult
- system_coordinator::SystemConfig
- system_coordinator::SystemCoordinator
- system_coordinator::SystemStatus
- test_utils::MockConfig
- test_utils::MockPeer
- test_utils::MockPeerBuilder
- test_utils::TempDir
- tier_migration::MigrationConfig
- tier_migration::MigrationResult
- tier_migration::MigrationTask
- tier_migration::TierMigration
- tiered_cache::TieredCache
- tiered_cache::TieredCacheConfig
- tiered_cache::TieredCacheStats
- tiered_storage::ContentLocation
- tiered_storage::PendingMove
- tiered_storage::RebalanceResult
- tiered_storage::TierConfig
- tiered_storage::TierStats
- tiered_storage::TieredStorageConfig
- tiered_storage::TieredStorageManager
- tracing::Span
- tracing::SpanEvent
- tracing::SpanGuard
- tracing::TraceContext
- tracing::TracingConfig
- tracing::TracingManager
- tracing::TracingStats
- transaction::Transaction
- transaction::TransactionManager
- utils::LruCache
- utils::RetryConfig
- utils::RetryConfigBuilder
- utils::async_utils::Debouncer
- validation::ContentLimits
- wal::LogEntry
- wal::WriteAheadLog
Enums
- adaptive_retry::FailureType
- alerting::AlertMetric
- alerting::AlertSeverity
- anomaly::AnomalyType
- auto_repair::ChunkRepairStatus
- auto_repair::RepairError
- backup::BackupError
- backup::BackupType
- bandwidth_estimation::CongestionState
- batch::BatchError
- cache_admission::Segment
- cache_invalidation::InvalidationError
- cache_invalidation::InvalidationPattern
- cache_invalidation::InvalidationReason
- cache_warming::WarmingError
- cache_warming::WarmingStrategy
- checkpoint::CheckpointError
- chunk_encryption::ChunkEncryptionError
- circuit_breaker::CircuitBreakerError
- circuit_breaker::CircuitState
- compression::CompressionAlgorithm
- compression::CompressionError
- config::ConfigError
- connection_multiplexing::ConnectionError
- content_aware_cache::ContentType
- content_router::RoutingStrategy
- custom_exporters::MetricValue
- custom_exporters::TimePrecision
- dashboard::SystemStatus
- dedup::StoreResult
- degradation::ServiceDegradationLevel
- events::EventPayload
- events::EventType
- events::PayloadFilter
- expiration::ExpirationPolicy
- forecasting::ForecastMethod
- health::HealthStatus
- http_pool::HttpError
- integrity::IntegrityError
- integrity::RepairStrategy
- lifecycle::LifecycleEventType
- logging::LogLevel
- metrics::MetricType
- metrics_exporter::ExportFormat
- metrics_exporter::MetricValue
- network_diag::ConnectionQuality
- node::NodeError
- orchestrator::OrchestratorError
- orchestrator::RetrievalStrategy
- partial_chunk::RangeError
- peer_selection::SelectionStrategy
- pinning::PinDecision
- pinning::PinRecommendation
- popularity::DemandLevel
- prefetch::PatternType
- proof_submit::ProofSubmitError
- proof_submit::SubmitState
- protocol::ValidationError
- qos::Priority
- request_pipeline::PipelineError
- request_pipeline::RequestPriority
- resource_mgmt::DegradationLevel
- resource_mgmt::ResourceType
- storage::RepairStatus
- storage::StorageError
- storage::StorageHealthStatus
- storage_health::HealthMonitorError
- storage_health::PredictiveHealthStatus
- streaming::StreamError
- streaming_verification::VerificationError
- system_coordinator::CoordinatorError
- tier_migration::MigrationError
- tier_migration::MigrationStatus
- tiered_cache::CacheTier
- tiered_cache::TieredCacheError
- tiered_storage::StorageTier
- tracing::TracingError
- transaction::TransactionError
- transaction::TransactionState
- validation::ContentValidationError
- wal::Operation
- wal::WalError
Traits
Macros
Functions
- backup::apply_retention_policy
- batch::parallel_map
- chunk_encryption::decrypt_chunk
- chunk_encryption::decrypt_content
- chunk_encryption::derive_chunk_key
- chunk_encryption::derive_chunk_nonce
- chunk_encryption::encrypt_chunk_with_index
- chunk_encryption::encrypt_content
- compression::suggest_algorithm_for_content
- dedup::find_duplicates
- gc::run_gc_once
- geo_selection::haversine_distance
- geo_selection::midpoint
- integrity::verify_content
- integrity::verify_single_chunk
- metrics::create_standard_registry
- profiler::global_profiler
- profiler::init_global_profiler
- protocol::calculate_latency
- protocol::create_bandwidth_proof
- protocol::create_chunk_request
- protocol::generate_challenge_nonce
- protocol::is_nonce_unique
- protocol::is_valid_cid
- protocol::validate_bandwidth_proof
- protocol::validate_chunk_request
- protocol::validate_chunk_response
- storage::calculate_chunk_count
- storage::split_into_chunks
- streaming::stream_copy
- test_utils::assert_approx_eq
- test_utils::random_bytes
- test_utils::random_cid
- test_utils::random_peer_id
- tracing::get_tracing_stats
- tracing::reset_tracing_stats
- tracing::span_scope
- tracing::span_with_attributes
- utils::align_down
- utils::align_up
- utils::async_utils::retry_async
- utils::async_utils::sleep
- utils::async_utils::sleep_ms
- utils::async_utils::sleep_secs
- utils::async_utils::timeout
- utils::average_u64
- utils::bytes_per_sec_to_mbps
- utils::bytes_to_gb
- utils::bytes_to_gb_f64
- utils::bytes_to_human_readable
- utils::bytes_to_kb
- utils::bytes_to_kb_f64
- utils::bytes_to_mb
- utils::bytes_to_mb_f64
- utils::bytes_to_tb_f64
- utils::calculate_bandwidth_gbps
- utils::calculate_bandwidth_mbps
- utils::calculate_percentage
- utils::calculate_percentage_rounded
- utils::chunk_size_with_overhead
- utils::cid_to_path_safe
- utils::clamp_const
- utils::current_timestamp_ms
- utils::days_to_duration
- utils::div_ceil
- utils::estimate_time_remaining
- utils::exponential_backoff
- utils::format_duration
- utils::format_duration_compact
- utils::format_number_with_commas
- utils::gb_to_bytes
- utils::gb_to_mb
- utils::hours_to_duration
- utils::is_in_range
- utils::is_power_of_two
- utils::is_timestamp_recent
- utils::is_valid_cid_format
- utils::is_valid_identifier
- utils::is_valid_peer_id
- utils::kb_to_bytes
- utils::larger_of
- utils::max_const
- utils::mb_to_bytes
- utils::mb_to_kb
- utils::mbps_to_bytes_per_sec
- utils::millis_to_duration
- utils::min_const
- utils::minutes_to_duration
- utils::normalize_cid
- utils::peer_id_hash
- utils::percentage_const
- utils::round_down_to_multiple
- utils::round_up_to_multiple
- utils::safe_slice
- utils::saturating_add_const
- utils::saturating_mul_const
- utils::saturating_sub_const
- utils::secs_to_duration
- utils::smaller_of
- utils::tb_to_bytes
- utils::tb_to_gb
- utils::timestamp_age
- utils::timestamp_to_duration
- utils::timestamp_to_systemtime
- utils::truncate_string
- utils::truncate_with_ellipsis
- utils::validate_peer_id
- validation::calculate_expected_chunks
- validation::sanitize_cid
- validation::validate_bandwidth
- validation::validate_chunk_index
- validation::validate_content_size
- validation::validate_proof_structure
- validation::validate_request_timestamp
- validation::validate_response_signature