Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 74 for queueLengthLimit (0.2 sec)

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