List of all items
Structs
- ActiveWorkerRow
- AfterJobRun
- AfterJobRunContext
- BeforeJobRun
- BeforeJobRunContext
- BeforeJobSchedule
- BeforeJobScheduleContext
- CronJobScheduled
- CronJobScheduledContext
- CronTick
- CronTickContext
- Crontab
- CrontabFill
- CrontabTimer
- Database
- DbError
- DbJob
- DbJobData
- DbParams
- DbRow
- DbTransaction
- HookRegistry
- Job
- JobBuilder
- JobComplete
- JobCompleteContext
- JobDefinition
- JobFail
- JobFailContext
- JobFetch
- JobFetchContext
- JobInterrupted
- JobInterruptedContext
- JobPermanentlyFail
- JobPermanentlyFailContext
- JobRecovery
- JobRecoveryContext
- JobSpec
- JobSpecBuilder
- JobStart
- JobStartContext
- LocalQueueGetJobsComplete
- LocalQueueGetJobsCompleteContext
- LocalQueueInit
- LocalQueueInitContext
- LocalQueueRefetchDelayAbort
- LocalQueueRefetchDelayAbortContext
- LocalQueueRefetchDelayExpired
- LocalQueueRefetchDelayExpiredContext
- LocalQueueRefetchDelayStart
- LocalQueueRefetchDelayStartContext
- LocalQueueReturnJobs
- LocalQueueReturnJobsContext
- LocalQueueSetMode
- LocalQueueSetModeContext
- Notification
- RawJobSpec
- Schema
- SharedTaskDetails
- SweepStaleWorkersOptions
- SweepStaleWorkersResult
- TaskDetails
- WorkerContext
- WorkerContextBuilder
- WorkerInit
- WorkerInitContext
- WorkerRecovered
- WorkerRecoveredContext
- WorkerRecoveryConfig
- WorkerShutdown
- WorkerShutdownConfig
- WorkerShutdownContext
- WorkerStart
- WorkerStartContext
- WorkerUtils
- builder::WorkerOptions
- cron::Cron
- cron::CronBuilder
- local_queue::LocalQueue
- local_queue::LocalQueueConfig
- local_queue::LocalQueueConfigBuilder
- local_queue::LocalQueueParams
- local_queue::RefetchDelayConfig
- local_queue::RefetchDelayConfigBuilder
- recovery::ActiveWorkerRow
- recovery::ResolvedSweepConfig
- recovery::SweepStaleWorkersOptions
- recovery::SweepStaleWorkersResult
- recovery::WorkerRecoveryConfig
- runner::ReleaseJobError
- runner::Worker
- sql::add_job::types::JobToAdd
- sql::add_job::types::RawJobSpec
- sql::fail_job::batch::FailedJob
- sql::task_identifiers::SharedTaskDetails
- sql::task_identifiers::TaskDetails
- sql::worker_heartbeat::active::ActiveWorkerRow
- sqlx::SqlxDatabase
- worker_utils::WorkerUtils
- worker_utils::client::WorkerUtils
- worker_utils::types::RescheduleJobOptions
Enums
- BatchTaskResult
- CronJobKeyMode
- CrontabField
- CrontabTimerError
- CrontabValue
- DbCell
- DbValue
- FailureReason
- HookResult
- JobKeyMode
- JobRecoveryResult
- JobScheduleResult
- JobSpecBuilderError
- LocalQueueMode
- ShutdownReason
- TaskHandlerOutcome
- builder::WorkerBuildError
- errors::GraphileWorkerError
- local_queue::LocalQueueConfigError
- local_queue::LocalQueueError
- local_queue::LocalQueueMode
- runner::WorkerRuntimeError
- streams::StreamSource
- worker_utils::types::CleanupTask
Traits
- BatchTaskHandler
- DatabaseDriver
- DbExecutor
- DbExecutorArg
- Event
- FromDbCell
- HookOutput
- Interceptable
- IntoBatchTaskHandlerResult
- IntoTaskHandlerResult
- Plugin
- TaskHandler
- TransactionDriver
- builder::CronInput
- context_ext::WorkerContextExt
Functions
- escape_identifier
- parse_crontab
- recovery::job_has_resilient_flag
- row_mapping::cells
- run_task_from_worker_ctx
- sql::add_job::batch::add_jobs
- sql::add_job::single::add_job
- sql::batch_get_jobs::batch_get_jobs
- sql::complete_job::complete_job
- sql::fail_job::batch::fail_jobs
- sql::fail_job::single::fail_job
- sql::get_job::get_job
- sql::recover_workers::get_locked_jobs_for_recovery
- sql::recover_workers::recover_dead_worker_jobs
- sql::return_jobs::batch::return_jobs
- sql::return_jobs::recovery::return_job_for_recovery
- sql::rows::db_job_from_row
- sql::task_identifiers::get_tasks_details
- sql::worker_heartbeat::active::list_active_workers
- sql::worker_heartbeat::lock::try_acquire_sweep_lock
- sql::worker_heartbeat::registration::worker_deregister
- sql::worker_heartbeat::registration::worker_heartbeat
- sql::worker_heartbeat::stale::delete_stale_workers
- sql::worker_heartbeat::stale::get_worker_last_heartbeat
- sql::worker_heartbeat::stale::list_orphan_locked_workers
- sql::worker_heartbeat::stale::list_stale_workers
- sql::worker_heartbeat::stale::worker_holds_resilient_locks
- streams::job_signal_stream
- streams::job_signal_stream_with_receiver
- streams::job_stream
Type Aliases
- BoxFuture
- NotificationStream
- TaskHandlerFn
- errors::Result
- runner::WorkerFn
- streams::JobSignalReceiver
- streams::JobSignalSender