Struct QueuingConfiguration

pub struct QueuingConfiguration {
    pub hand_size: Option<i32>,
    pub queue_length_limit: Option<i32>,
    pub queues: Option<i32>,
}

QueuingConfiguration holds the configuration parameters for queuing

Fields

hand_size: Option<i32>

handSize is a small positive number that configures the shuffle sharding of requests into queues. When enqueuing a request at this priority level the request’s flow identifier (a string pair) is hashed and the hash value is used to shuffle the list of queues and deal a hand of the size specified here. The request is put into one of the shortest queues in that hand. handSize must be no larger than queues, and should be significantly smaller (so that a few heavy flows do not saturate most of the queues). See the user-facing documentation for more extensive guidance on setting this field. This field has a default value of 8.

queue_length_limit: Option<i32>

queueLengthLimit is the maximum number of requests allowed to be waiting in a given queue of this priority level at a time; excess requests are rejected. This value must be positive. If not specified, it will be defaulted to 50.

queues: Option<i32>

queues is the number of queues for this priority level. The queues exist independently at each apiserver. The value must be positive. Setting it to 1 effectively precludes shufflesharding and thus makes the distinguisher method of associated flow schemas irrelevant. This field has a default value of 64.

Trait Implementations

impl Clone for QueuingConfiguration

fn clone(&self) -> QueuingConfiguration

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for QueuingConfiguration

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

Formats the value using the given formatter.

impl DeepMerge for QueuingConfiguration

fn merge_from(&mut self, other: Self)

Merge other into self.

impl Default for QueuingConfiguration

fn default() -> QueuingConfiguration

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for QueuingConfiguration

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for QueuingConfiguration

fn eq(&self, other: &QueuingConfiguration) -> 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 QueuingConfiguration

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 QueuingConfiguration