Struct AdmissionQueue 

pub struct AdmissionQueue {
    pub enabled: bool,
    pub max_queue_size: u32,
    pub queue_timeout_ms: u64,
    pub per_priority: bool,
}

Bounded admission queue config (DW-053, gateway.admission_queue).

When enabled and the concurrency cap is full, requests wait for a permit up to queue_timeout_ms instead of being immediately shed. The queue depth is bounded by max_queue_size; once full, further requests are shed immediately with 503 (the queue_full outcome). Per-priority splitting (per_priority: true, the default) reserves a fraction of queue capacity for high-priority requests so they are not starved by a low-priority queue fill.

Fields

enabled: bool

Master switch. Default false: the queue is inert and the gateway sheds immediately on cap saturation (DW-016 behavior). Requires max_concurrent_requests (validation rejects an enabled queue on an uncapped gateway).

max_queue_size: u32

Total number of requests that may wait for a permit across all priority classes (1..=10000). Once the queue is at capacity, further over-cap requests are shed immediately with 503 (the queue_full outcome).

queue_timeout_ms: u64

Maximum time a request waits for a permit, in milliseconds (1..=10000). If the timeout expires before a permit becomes available, the request is shed with 503 (the timeout outcome) and a Retry-After header.

per_priority: bool

Split queue capacity across priority classes (default true). When true, a fraction of max_queue_size is reserved for high-priority requests (priority >= 8) so they are not starved by a low-priority queue fill. When false, the queue is a single shared pool (first-come-first-served).

Trait Implementations

impl Clone for AdmissionQueue

fn clone(&self) -> AdmissionQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AdmissionQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AdmissionQueue

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for AdmissionQueue

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for AdmissionQueue

fn eq(&self, other: &AdmissionQueue) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for AdmissionQueue

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AdmissionQueue