List of all items
Structs
- admin::CallbackConfig
- admin::CallbackDump
- admin::JobDump
- admin::JobDumpSummary
- admin::JobKindDescriptor
- admin::JobKindOverview
- admin::JobTimelineEvent
- admin::ListJobsFilter
- admin::NamedJobKindDescriptor
- admin::NamedQueueDescriptor
- admin::QueueDescriptor
- admin::QueueOverview
- admin::QueueRuntimeConfigSnapshot
- admin::QueueRuntimeSnapshot
- admin::QueueRuntimeSummary
- admin::RateLimitSnapshot
- admin::RetryFailedOutcome
- admin::RunDump
- admin::RuntimeInstance
- admin::RuntimeOverview
- admin::RuntimeSnapshotInput
- admin::StateTimeseriesBucket
- batch_operations::BatchOperation
- batch_operations::BatchOperationCursor
- batch_operations::BatchOperationFilter
- batch_operations::BatchOperationPreview
- batch_operations::BatchOperationRunOutcome
- batch_operations::ListBatchOperationsFilter
- batch_operations::SubmitBatchOperation
- callback_contract::CallbackResponse
- callback_contract::CompletePayload
- callback_contract::FailPayload
- callback_contract::HeartbeatPayload
- cron::CronJobRow
- cron::PeriodicJob
- cron::PeriodicJobBuilder
- dlq::DlqMetadata
- dlq::DlqRow
- dlq::ListDlqFilter
- dlq::RetryFromDlqOpts
- insert::PreparedJobInsert
- job::InsertOpts
- job::InsertParams
- job::JobRow
- job::UniqueOpts
- partitioned_queue::PartitionedQueue
- queue_storage::BusyCounts
- queue_storage::ClaimedEntry
- queue_storage::ClaimedRuntimeJob
- queue_storage::QueueClaimerLease
- queue_storage::QueueClaimerState
- queue_storage::QueueCounts
- queue_storage::QueueStorage
- queue_storage::QueueStorageConfig
- queue_storage::TerminalDeltaRollupOutcome
- storage::BacklogSample
- storage::StorageStatus
- storage::StorageStatusReport
Enums
- admin::CallbackPollResult
- admin::DefaultAction
- admin::QueueRuntimeMode
- admin::ResolveOutcome
- admin::RunDumpSource
- admin::StorageCapability
- admin::TransitionRole
- batch_operations::BatchOperationKind
- batch_operations::BatchOperationSpec
- batch_operations::BatchOperationState
- cron::CronMissedFirePolicy
- error::AwaError
- job::JobState
- partitioned_queue::PartitionedQueueError
- queue_storage::PruneOutcome
- queue_storage::RotateOutcome
- queue_storage::SkipReason
Traits
Derive Macros
Functions
- admin::bulk_cancel
- admin::bulk_retry
- admin::cancel
- admin::cancel_by_unique_key
- admin::cancel_by_unique_key_tx
- admin::cancel_callback
- admin::cancel_tx
- admin::check_callback_state
- admin::cleanup_runtime_snapshots
- admin::cleanup_stale_descriptors
- admin::complete_external
- admin::complete_external_in_tx
- admin::discard_failed
- admin::distinct_kinds
- admin::distinct_queues
- admin::drain_queue
- admin::dump_job
- admin::dump_run
- admin::enter_callback_wait
- admin::fail_external
- admin::fail_external_in_tx
- admin::flush_dirty_admin_metadata
- admin::get_job
- admin::get_job_with_source
- admin::heartbeat_callback
- admin::job_kind_descriptors_for_names
- admin::job_kind_overview
- admin::job_kind_overviews
- admin::list_jobs
- admin::list_runtime_instances
- admin::pause_queue
- admin::queue_descriptors_for_names
- admin::queue_overview
- admin::queue_overviews
- admin::queue_runtime_summary
- admin::recompute_dirty_admin_metadata
- admin::refresh_admin_metadata
- admin::register_callback
- admin::register_callback_with_config
- admin::resolve_callback
- admin::resolve_callback_in_tx
- admin::resume_external
- admin::resume_external_in_tx
- admin::resume_queue
- admin::retry
- admin::retry_external
- admin::retry_external_in_tx
- admin::retry_failed_by_kind
- admin::retry_failed_by_queue
- admin::runtime_overview
- admin::state_counts
- admin::state_timeseries
- admin::sync_job_kind_descriptors
- admin::sync_queue_descriptors
- admin::take_callback_payload
- admin::upsert_runtime_snapshot
- batch_operations::cleanup_expired_batch_operations
- batch_operations::finalize_expired_batch_operation_retention
- batch_operations::get_batch_operation
- batch_operations::list_batch_operations
- batch_operations::preview_batch_operation
- batch_operations::purge_batch_operations_before
- batch_operations::request_batch_operation_cancellation
- batch_operations::run_one_batch_operation_chunk
- batch_operations::run_one_default_chunk
- batch_operations::submit_batch_operation
- callback_contract::callback_url
- callback_contract::sign
- callback_contract::verify
- cron::atomic_enqueue
- cron::delete_cron_job
- cron::list_cron_jobs
- cron::next_fire_time
- cron::next_fire_time_after
- cron::pause_cron_job
- cron::resume_cron_job
- cron::trigger_cron_job
- cron::upsert_cron_job
- dlq::bulk_move_failed_to_dlq
- dlq::bulk_retry_from_dlq
- dlq::cleanup_dlq
- dlq::dlq_depth
- dlq::dlq_depth_by_queue
- dlq::get_dlq_job
- dlq::list_dlq
- dlq::move_failed_to_dlq
- dlq::purge_dlq
- dlq::purge_dlq_job
- dlq::retry_from_dlq
- error::map_sqlx_error
- insert::insert
- insert::insert_many
- insert::insert_many_copy
- insert::insert_many_copy_from_pool
- insert::insert_with
- insert::params
- insert::params_with
- insert::prepare_job_insert
- insert::prepare_raw_job_insert
- kind::camel_to_snake
- migrations::current_version
- migrations::migration_sql
- migrations::migration_sql_range
- migrations::run
- partitioned_queue::partition_for_ordering_key
- partitioned_queue::partition_hash64
- queue_storage::ordering_key_hash64
- queue_storage::shard_for_ordering_key
- storage::abort
- storage::enter_mixed_transition
- storage::finalize
- storage::prepare
- storage::queue_storage_schema_ready
- storage::status
- storage::status_report
- unique::compute_unique_key