- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for queueLengthLimit (0.32 sec)
-
staging/src/k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap/default.go
LimitResponse: flowcontrol.LimitResponse{ Type: flowcontrol.LimitResponseTypeQueue, Queuing: &flowcontrol.QueuingConfiguration{ Queues: 64, HandSize: 6, QueueLengthLimit: 50, }, }, }, }) SuggestedPriorityLevelConfigurationNodeHigh = newPriorityLevelConfiguration( "node-high", flowcontrol.PriorityLevelConfigurationSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go
func (b *plBuilder) WithQueuing(queues, handSize, queueLengthLimit int32) *plBuilder { limited := b.object.Spec.Limited if limited == nil { return b } limited.LimitResponse.Type = flowcontrolv1.LimitResponseTypeQueue limited.LimitResponse.Queuing = &flowcontrolv1.QueuingConfiguration{ Queues: queues, HandSize: handSize, QueueLengthLimit: queueLengthLimit, } return b
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 19.8K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta1/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: Sun Sep 17 09:27:57 UTC 2023 - 31.2K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1beta2/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: Sun Sep 17 09:27:57 UTC 2023 - 31.2K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/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: Thu May 23 17:42:49 UTC 2024 - 31.1K bytes - Viewed (0) -
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/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)