List of all items

Structs

• CronJob
• RRQSettings
• RunnerConfig
• WatchSettings
• client::EnqueueOptions
• client::RRQClient
• job::Job
• runner::SocketRunner
• runner::SocketRunnerPool
• store::JobStore
• worker::RRQWorker

Enums

• RunnerManagementMode
• RunnerType
• job::JobStatus
• runner::RunnerExecutionResult
• telemetry::LogFormat

Traits

• runner::Runner

Functions

• load_toml_settings
• load_toml_settings_with_runner_mode
• resolve_config_source
• runner::build_runners_from_settings
• runner::build_runners_from_settings_filtered
• runner::determine_needed_runners
• runner::resolve_runner_max_in_flight
• runner::resolve_runner_pool_sizes
• telemetry::apply_correlation_context_to_span
• telemetry::extract_correlation_context
• telemetry::init_tracing
• telemetry::inject_current_trace_context
• telemetry::log_format
• telemetry::record_claim_attempt
• telemetry::record_claim_miss
• telemetry::record_enqueue
• telemetry::record_job_processed
• telemetry::record_jobs_fetched
• telemetry::record_lock_acquire
• telemetry::record_orphan_recovered
• telemetry::record_poll_cycle
• telemetry::record_queue_wait_ms
• telemetry::set_parent_from_trace_context
• telemetry::shutdown_tracing

Constants

• constants::ACTIVE_JOBS_PREFIX
• constants::DEFAULT_DLQ_NAME
• constants::DEFAULT_DLQ_RESULT_TTL_SECONDS
• constants::DEFAULT_EXPECTED_JOB_TTL
• constants::DEFAULT_JOB_TIMEOUT_SECONDS
• constants::DEFAULT_LOCK_TIMEOUT_EXTENSION_SECONDS
• constants::DEFAULT_MAX_RETRIES
• constants::DEFAULT_POLL_DELAY_SECONDS
• constants::DEFAULT_QUEUE_NAME
• constants::DEFAULT_RESULT_TTL_SECONDS
• constants::DEFAULT_RUNNER_CONNECT_TIMEOUT_MS
• constants::DEFAULT_UNIQUE_JOB_LOCK_TTL_SECONDS
• constants::DEFAULT_WORKER_ID_PREFIX
• constants::DLQ_KEY_PREFIX
• constants::HEALTH_KEY_PREFIX
• constants::JOB_EVENTS_KEY_PREFIX
• constants::JOB_KEY_PREFIX
• constants::LOCK_KEY_PREFIX
• constants::QUEUE_KEY_PREFIX
• constants::UNIQUE_JOB_LOCK_PREFIX