List of all items

Structs

• catalog::CatalogJobEnqueueInput
• catalog::CatalogJobScheduleInput
• catalog::CatalogJobScheduleSpec
• catalog::CatalogWorkflowDagBuilder
• catalog::JobCatalog
• catalog::JobCatalogDefaults
• catalog::JobCatalogDefinitionOverrides
• catalog::JobCatalogExactSyncReport
• catalog::JobCatalogScheduleSyncReport
• catalog::JobCatalogScheduleSyncScope
• catalog::JobCatalogSyncReport
• catalog::JobCatalogSyncScope
• config::JobsConfig
• observer::JobCompletionPersistFailedEvent
• observer::JobFailedEvent
• observer::JobLeaseLostEvent
• observer::JobLeaseReapedEvent
• observer::JobLifecycleObservers
• observer::JobRunningEvent
• observer::JobSucceededEvent
• observer::ObservedJob
• registry::JobRegistry
• supervisor::Supervisor
• supervisor::SupervisorBuilder
• supervisor::SupervisorShutdown

Enums

• RuntimeLoopExit
• catalog::CatalogError
• config::JobsConfigValidationError
• error::Error
• error::ReaperError
• error::RuntimeError
• error::SchedulerError
• error::WorkerError
• observer::JobCompletionPersistenceOperation
• observer::JobFailureDisposition
• observer::JobLeaseReapedDisposition
• registry::JobRegistryError

Traits

• observer::JobLifecycleObserver
• registry::JobHandler

Functions

• reaper::run_reaper_loop
• reaper::run_reaper_loop_with_observer
• scheduler::run_scheduler_loop
• worker::run_worker_loop
• worker::run_worker_loop_with_observer

Type Aliases

• error::Result

Constants

• config::JOBS_CLAIM_BATCH_SIZE_MAX