List of all items

Structs

• JobContext
• LoggingEventEmitter
• NoopEventEmitter
• config::QueueConfig
• config::QueueConfigBuilder
• events::JobCancelledEvent
• events::JobCompletedEvent
• events::JobFailedEvent
• events::JobProgressEvent
• events::JobStartedEvent
• executor::ProcessedJob
• executor::QueueExecutor
• queue::QueueManager
• types::JobResult
• types::QueueJob
• types::QueueJobDetails
• types::QueueStats

Enums

• error::QueueError
• types::FailureClass
• types::QueueJobStatus
• types::QueuePriority

Traits

• JobHandler
• QueueEventEmitter

Functions

• db::cancel_job
• db::claim
• db::claim_next_job
• db::claim_with_lease
• db::count_by_status
• db::get_attempt_count
• db::get_job
• db::get_job_details
• db::get_next_pending
• db::heartbeat
• db::insert_job
• db::insert_job_full
• db::insert_job_with_trace
• db::is_cancelled
• db::list_all_jobs
• db::mark_completed
• db::mark_completed_owned
• db::mark_failed
• db::mark_failed_owned
• db::mark_failed_with_retry
• db::mark_failed_with_retry_owned
• db::mark_processing
• db::open_database
• db::prune_old_jobs
• db::reclaim_stale
• db::reorder_pending
• db::requeue_interrupted
• db::update_canonical_lineage
• db::update_priority

Type Aliases

• db::JobRow