Module admin 

Structs

CallbackConfig

Configuration for CEL callback expressions.

ListJobsFilter

List jobs with optional filters.

QueueRuntimeConfigSnapshot

Per-queue configuration published by a worker runtime instance.

QueueRuntimeSnapshot

Runtime state for one queue on one worker instance.

QueueRuntimeSummary

Queue-centric runtime/config summary aggregated across worker instances.

QueueStats

Queue statistics.

RateLimitSnapshot

Snapshot of a per-queue rate limit configuration.

RuntimeInstance

A worker runtime instance as exposed through the admin API.

RuntimeOverview

Cluster-wide runtime overview.

RuntimeSnapshotInput

Data written by a worker runtime into the observability snapshot table.

StateTimeseriesBucket

A bucketed count of jobs by state over time.

Enums

CallbackPollResult

Result of a single poll iteration inside wait_for_callback.

DefaultAction

What resolve_callback should do if no CEL conditions match or no expressions are configured.

QueueRuntimeMode

Runtime concurrency mode for a queue.

ResolveOutcome

Outcome of resolve_callback.

Functions

bulk_cancel

Cancel multiple jobs by ID. Only cancels non-terminal jobs.

bulk_retry

Retry multiple jobs by ID. Only retries failed, cancelled, or waiting_external jobs.

cancel

Cancel a single non-terminal job.

cancel_by_unique_key

Cancel a job by its unique key components.

cancel_callback

Cancel (clear) a registered callback for a running job.

check_callback_state

Check the current state of a job during callback wait.

cleanup_runtime_snapshots

Opportunistically delete long-stale runtime snapshot rows.

complete_external

Complete a waiting job via external callback.

discard_failed

Discard (delete) all failed jobs of a given kind.

distinct_kinds

Return all distinct job kinds.

distinct_queues

Return all distinct queue names.

drain_queue

Drain a queue: cancel all non-running, non-terminal jobs.

enter_callback_wait

Transition a running job to waiting_external for the given callback.

fail_external

Fail a waiting job via external callback.

flush_dirty_admin_metadata

Drain ALL dirty keys until the backlog is empty.

get_job

Get a single job by ID.

heartbeat_callback

Reset the callback timeout for a long-running external operation.

list_jobs

List jobs matching the given filter.

list_runtime_instances

List all runtime instances ordered with leader/live instances first.

pause_queue

Pause a queue. Affects all workers immediately.

queue_runtime_summary

Queue runtime/config summary aggregated across worker snapshots.

queue_stats

Get statistics for all queues.

recompute_dirty_admin_metadata

Drain one batch of dirty keys and recompute exact cached rows. Returns the number of dirty keys processed in this batch.

refresh_admin_metadata

Full reconciliation of admin metadata counters from base tables.

register_callback

Register a callback for a running job, writing the callback_id and timeout to the database immediately.

register_callback_with_config

Register a callback with optional CEL expressions.

resolve_callback

Resolve a callback by evaluating CEL expressions against the payload.

resume_external

Complete a waiting job and resume the handler with the callback payload.

resume_queue

Resume a paused queue.

retry

Retry a single failed, cancelled, or waiting_external job.

retry_external

Retry a waiting job via external callback.

retry_failed_by_kind

Retry all failed jobs of a given kind.

retry_failed_by_queue

Retry all failed jobs in a given queue.

runtime_overview

Cluster runtime overview with instance list.

state_counts

Count jobs grouped by state.

state_timeseries

Return time-bucketed state counts over the last N minutes.

take_callback_payload

Extract the _awa_callback_result key from metadata and clean it up.

upsert_runtime_snapshot

Upsert a runtime observability snapshot for one worker instance.