Skip to main content

sync_queue_descriptors

awa_model::admin

Function sync_queue_descriptors 

Source 
pub async fn sync_queue_descriptors(
    pool: &PgPool,
    descriptors: &[NamedQueueDescriptor],
    sync_interval: Duration,
) -> Result<(), AwaError>
Expand description

Upsert queue descriptors declared by the worker runtime.

Descriptor rows are part of the control-plane catalog and intentionally separate from mutable queue runtime state in awa.queue_meta.

Descriptors are upserted in batched multi-row statements — one round-trip per [DESCRIPTOR_BATCH_SIZE] descriptors rather than one per descriptor. For typical fleets (≤100 queues / ≤500 kinds) that collapses to a single round-trip per sync call.