- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 74 for queueLengthLimit (0.2 sec)
-
pkg/apis/flowcontrol/validation/validation.go
func ValidatePriorityLevelQueuingConfiguration(queuing *flowcontrol.QueuingConfiguration, fldPath *field.Path) field.ErrorList { var allErrs field.ErrorList if queuing.QueueLengthLimit <= 0 { allErrs = append(allErrs, field.Invalid(fldPath.Child("queueLengthLimit"), queuing.QueueLengthLimit, "must be positive")) } // validate input arguments for shuffle-sharding if queuing.Queues <= 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 26.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
qs.queues = append(qs.queues, createQueues(qCfg.DesiredNumQueues-numQueues, len(qs.queues))...) } } else { qCfg.QueueLengthLimit = qs.qCfg.QueueLengthLimit qCfg.HandSize = qs.qCfg.HandSize } qs.qCfg = qCfg qs.dCfg = dCfg qs.dealer = dealer qll := qCfg.QueueLengthLimit if qll < 1 { qll = 1 } if qCfg.DesiredNumQueues > 0 { qll *= qCfg.DesiredNumQueues }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta3/types.go
// `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. // +optional QueueLengthLimit int32 `json:"queueLengthLimit" protobuf:"varint,3,opt,name=queueLengthLimit"` }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 31.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go
Type: flowcontrol.LimitResponseTypeQueue, Queuing: &flowcontrol.QueuingConfiguration{ Queues: 10, HandSize: 2, QueueLengthLimit: 10, }, }, }, }, } cfgObjs = append(cfgObjs, fsObjs[flow], plcObjs[flow]) } clientset := clientsetfake.NewSimpleClientset(cfgObjs...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 9K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta1/zz_generated.conversion.go
out.Queues = in.Queues out.HandSize = in.HandSize out.QueueLengthLimit = in.QueueLengthLimit return nil } // Convert_v1beta1_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 53.5K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta2/zz_generated.conversion.go
out.Queues = in.Queues out.HandSize = in.HandSize out.QueueLengthLimit = in.QueueLengthLimit return nil } // Convert_v1beta2_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 53.5K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/types_swagger_doc_generated.go
"queueLengthLimit": "`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.", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 21.7K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta3/types_swagger_doc_generated.go
"queueLengthLimit": "`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.", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 21.5K bytes - Viewed (0) -
common-protos/k8s.io/api/flowcontrol/v1beta1/generated.proto
// +optional optional int32 handSize = 2; // `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. // +optional optional int32 queueLengthLimit = 3; } // ResourcePolicyRule is a predicate that matches some resource
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.4K bytes - Viewed (0) -
common-protos/k8s.io/api/flowcontrol/v1alpha1/generated.proto
// +optional optional int32 handSize = 2; // `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. // +optional optional int32 queueLengthLimit = 3; } // ResourcePolicyRule is a predicate that matches some resource
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.4K bytes - Viewed (0)