List of all items

Structs

• DistributedConfig
• DistributedEncoder
• DistributedJob
• EncodingParams
• audit_log::AuditEntry
• audit_log::AuditEntryBuilder
• audit_log::AuditLog
• audit_log::AuditLogConfig
• backpressure::BackpressureAggregator
• backpressure::CreditAccount
• backpressure::NodeBackpressure
• backpressure::TokenBucket
• checkpointing::Checkpoint
• checkpointing::CheckpointId
• checkpointing::CheckpointPolicy
• checkpointing::CheckpointStore
• checkpointing::RecoveryEstimate
• checkpointing::RecoveryPlanner
• circuit_breaker::CircuitBreaker
• circuit_breaker::CircuitBreakerConfig
• circuit_breaker::SlidingWindow
• cluster::ClusterNode
• cluster::ClusterTopology
• compaction::LogCompactor
• compaction::Snapshot
• connection_pool::ConnectionPool
• connection_pool::ConnectionPoolConfig
• connection_pool::PoolStats
• connection_pool::PooledConnection
• connection_pool::RetryPolicy
• consensus::ElectionTimer
• consensus::LogEntry
• consensus::NodeId
• consensus::RaftLog
• consensus::RaftNode
• consensus::RaftTerm
• consensus::VoteRequest
• consensus::VoteResponse
• coordinator::Coordinator
• coordinator::CoordinatorConfig
• coordinator::CoordinatorStatistics
• discovery::CapacityStats
• discovery::DiscoveryConfig
• discovery::DiscoveryService
• discovery::GeoLocation
• discovery::HealthCheckStats
• discovery::HealthChecker
• discovery::RegisteredWorker
• discovery::WorkerCapabilities
• discovery::WorkerEndpoint
• discovery::WorkerRegistry
• distributed_enhancements::BackpressureController
• distributed_enhancements::CheckpointCoordinator
• distributed_enhancements::ConsistentHashRing
• distributed_enhancements::DistributedCheckpoint
• distributed_enhancements::DistributedCircuitBreaker
• distributed_enhancements::LogEntry
• distributed_enhancements::RaftNode
• distributed_enhancements::RaftState
• distributed_enhancements::ReplicationManager
• distributed_enhancements::ServiceRegistry
• distributed_enhancements::SimpleShardMap
• distributed_enhancements::VoteResponse
• distributed_enhancements::WorkStealingQueue
• fault_tolerance::CircuitBreaker
• fault_tolerance::FaultManager
• fault_tolerance::NodeFailure
• geo_placement::GeoPlacementPolicy
• geo_placement::Region
• geo_placement::WorkerRegion
• heartbeat::HeartbeatConfig
• heartbeat::HeartbeatTracker
• heartbeat::NodeHeartbeatRecord
• job_dag::JobDag
• job_preemption::PreemptibleJob
• job_preemption::PreemptionEvent
• job_preemption::PreemptionScheduler
• job_tracker::DistributedJob
• job_tracker::JobTracker
• leader_election::ElectionManager
• leader_election::NodeVote
• lease::LeaderLease
• load_balancer::LoadBalancer
• load_balancer::WorkerLoad
• membership::ClusterMembership
• message_bus::BusMessage
• message_bus::BusStats
• message_bus::MessageBus
• message_bus::SubscriptionId
• message_queue::DistributedMessage
• message_queue::MessageQueue
• metrics_aggregator::Alert
• metrics_aggregator::AlertEvaluator
• metrics_aggregator::AlertRule
• metrics_aggregator::ClusterMetrics
• metrics_aggregator::MetricAggregator
• metrics_aggregator::MetricPoint
• node_health::HealthCheckConfig
• node_health::HealthRegistry
• node_health::NodeHealthCheck
• node_registry::NodeInfo
• node_registry::NodeRegistry
• node_topology::NodeLocation
• node_topology::TopologyManager
• node_topology::TopologyNode
• notifications::JobEvent
• notifications::NotificationBus
• partition::ClusterNode
• partition::ConsistentHashRing
• partition::Partition
• partition::PartitionTable
• pb::CancellationResponse
• pb::EncodingParams
• pb::EncodingTask
• pb::FailureAcknowledgment
• pb::GopSegment
• pb::HeartbeatResponse
• pb::Job
• pb::JobAssignment
• pb::JobCancellation
• pb::JobFailure
• pb::JobRequest
• pb::JobResult
• pb::JobStatusRequest
• pb::JobStatusResponse
• pb::ProgressAcknowledgment
• pb::ProgressReport
• pb::ResultAcknowledgment
• pb::ResultMetadata
• pb::TileSegment
• pb::TimeSegment
• pb::UnregistrationResponse
• pb::WorkerCapabilities
• pb::WorkerHeartbeat
• pb::WorkerInfo
• pb::WorkerMetrics
• pb::WorkerRegistration
• pb::WorkerRegistrationResponse
• pb::WorkerStatus
• pb::WorkerStatusRequest
• pb::WorkerStatusResponse
• pb::WorkerUnregistration
• pb::coordinator_service_client::CoordinatorServiceClient
• pb::coordinator_service_server::CoordinatorServiceServer
• pb::job_assignment::Job
• raft_primitives::LogEntry
• raft_primitives::RaftLog
• raft_primitives::RaftMetrics
• raft_primitives::RaftMetricsSnapshot
• raft_primitives::RaftState
• replication::LogEntry
• replication::QuorumHelper
• replication::ReplicatedLog
• replication::TermTracker
• resource_quota::QuotaManager
• resource_quota::ResourceLimits
• resource_quota::ResourceRequest
• resource_quota::ResourceUsage
• scheduler::BackfillingScheduler
• scheduler::JobScheduler
• scheduler::ResourceAllocation
• scheduler::ScheduledJob
• scheduler::SchedulerStats
• scheduler::SchedulingBuilder
• scheduler::TaskAffinity
• segment::BitrateAdjustment
• segment::GOPDetector
• segment::GOPInfo
• segment::ReassemblyResult
• segment::SegmentReassembler
• segment::VideoInfo
• segment::VideoSegment
• segment::VideoSegmenter
• segment_merge::GapInfo
• segment_merge::MergeConfig
• segment_merge::MergeResult
• segment_merge::SegmentInfo
• segment_merge::SegmentManifest
• segment_merge::SegmentMerger
• shard::ConsistentHashRing
• shard::ShardCatalog
• shard::ShardKey
• shard::ShardMetadata
• shard::VirtualNode
• shard_map::BatchAssignment
• shard_map::NodeId
• shard_map::ShardMap
• shard_map::ShardMapConfig
• snapshot_store::AuditEntry
• snapshot_store::AuditLog
• snapshot_store::Snapshot
• snapshot_store::SnapshotId
• snapshot_store::SnapshotStore
• task_distribution::AffinityScore
• task_distribution::MigrationPlanner
• task_distribution::TaskMigration
• task_distribution::TaskRequirements
• task_distribution::WorkerCapability
• task_distribution::WorkerStatus
• task_distribution::WorkloadBalancer
• task_priority_queue::PriorityTask
• task_priority_queue::TaskPriorityQueue
• task_queue::DistributedTask
• task_queue::TaskQueue
• task_retry::AttemptRecord
• task_retry::RetryPolicy
• task_retry::RetryTracker
• twopc::TwoPhaseCoordinator
• weighted_round_robin::WeightedRoundRobin
• work_stealing::StealableTask
• work_stealing::WorkQueue
• work_stealing::WorkStealingScheduler
• worker::Worker
• worker::WorkerCapabilities
• worker::WorkerConfig
• worker_draining::DrainManager

Enums

• DiscoveryMethod
• DistributedError
• JobPriority
• JobStatus
• SplitStrategy
• audit_log::AuditEventKind
• audit_log::AuditSeverity
• backpressure::BackpressureLevel
• circuit_breaker::CircuitEvent
• circuit_breaker::CircuitState
• cluster::NodeHealth
• cluster::NodeRole
• connection_pool::ConnectionState
• consensus::RaftRole
• coordinator::LoadBalancingStrategy
• discovery::HealthStatus
• discovery::RegistryBackend
• fault_tolerance::CircuitState
• fault_tolerance::FailureType
• heartbeat::NodeLiveness
• job_dag::DagError
• job_preemption::PreemptionPolicy
• job_preemption::PreemptionState
• job_tracker::JobState
• leader_election::ElectionState
• load_balancer::LoadBalanceStrategy
• message_bus::MessageType
• message_queue::MessagePriority
• metrics_aggregator::AggregationFn
• metrics_aggregator::Comparison
• node_health::HealthStatus
• node_registry::NodeRole
• node_registry::NodeStatus
• node_topology::LocationTier
• notifications::JobEventType
• pb::job_cancellation::Target
• pb::job_status_request::Query
• pb::worker_status_request::Query
• raft_primitives::RaftRole
• resource_quota::QuotaViolation
• scheduler::SchedulingPolicy
• segment::ConcatenationStrategy
• segment::SegmentType
• segment_merge::GapPolicy
• segment_merge::MergeStrategy
• shard::ShardState
• snapshot_store::AuditEventKind
• task_distribution::MigrationReason
• task_priority_queue::Priority
• task_queue::TaskPriority
• task_queue::TaskStatus
• task_retry::AttemptOutcome
• task_retry::BackoffStrategy
• task_retry::RetryDecision
• twopc::TwoPhaseState
• worker_draining::DrainError
• worker_draining::WorkerState

Traits

• pb::coordinator_service_server::CoordinatorService

Functions

• distributed_enhancements::fnv1a_hash
• distributed_enhancements::shard_assign
• geo_placement::select_worker_by_region
• load_balancer::consistent_hash
• shard_map::batch_assign

Type Aliases

• Result