Struct k8s_openapi::api::flowcontrol::v1::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 for QueuingConfiguration
impl PartialEq for QueuingConfiguration
source§impl Serialize for QueuingConfiguration
impl Serialize for QueuingConfiguration
impl StructuralPartialEq for QueuingConfiguration
Auto Trait Implementations§
impl Freeze for QueuingConfiguration
impl RefUnwindSafe for QueuingConfiguration
impl Send for QueuingConfiguration
impl Sync for QueuingConfiguration
impl Unpin for QueuingConfiguration
impl UnwindSafe for QueuingConfiguration
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)