Struct k8s_openapi::api::flowcontrol::v1beta3::QueuingConfiguration
source · pub struct QueuingConfiguration {
pub hand_size: Option<i32>,
pub queue_length_limit: Option<i32>,
pub queues: Option<i32>,
}
Expand description
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§
source§impl Clone for QueuingConfiguration
impl Clone for QueuingConfiguration
source§fn clone(&self) -> QueuingConfiguration
fn clone(&self) -> QueuingConfiguration
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for QueuingConfiguration
impl Debug for QueuingConfiguration
source§impl DeepMerge for QueuingConfiguration
impl DeepMerge for QueuingConfiguration
source§fn merge_from(&mut self, other: Self)
fn merge_from(&mut self, other: Self)
other
into self
.source§impl Default for QueuingConfiguration
impl Default for QueuingConfiguration
source§fn default() -> QueuingConfiguration
fn default() -> QueuingConfiguration
source§impl<'de> Deserialize<'de> for QueuingConfiguration
impl<'de> Deserialize<'de> for QueuingConfiguration
source§fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where D: Deserializer<'de>,
source§impl PartialEq<QueuingConfiguration> for QueuingConfiguration
impl PartialEq<QueuingConfiguration> for QueuingConfiguration
source§fn eq(&self, other: &QueuingConfiguration) -> bool
fn eq(&self, other: &QueuingConfiguration) -> bool
self
and other
values to be equal, and is used
by ==
.