Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for queueLengthLimit (0.32 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top