Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 74 for QueueLengthLimit (0.31 sec)

  1. pkg/apis/flowcontrol/validation/validation_test.go

    					LimitResponse: flowcontrol.LimitResponse{
    						Type: flowcontrol.LimitResponseTypeReject,
    						Queuing: &flowcontrol.QueuingConfiguration{
    							Queues:           512,
    							HandSize:         4,
    							QueueLengthLimit: 100,
    						}}}},
    		},
    		expectedErrors: field.ErrorList{field.Forbidden(field.NewPath("spec").Child("limited").Child("limitResponse").Child("queuing"), "must be nil if limited.limitResponse.type is not Limited")},
    	}, {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 54.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go

    	qsf := newTestableQueueSetFactory(clk, countingPromiseFactoryFactory(counter))
    	qCfg := fq.QueuingConfig{
    		Name:             "TestBaseline",
    		DesiredNumQueues: 9,
    		QueueLengthLimit: 8,
    		HandSize:         3,
    	}
    	seatDemandIntegratorSubject := fq.NewNamedIntegrator(clk, "seatDemandSubject")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 26 12:55:23 UTC 2023
    - 58.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go

    				LimitResponse: flowcontrol.LimitResponse{
    					Type: flowcontrol.LimitResponseTypeQueue,
    					Queuing: &flowcontrol.QueuingConfiguration{
    						Queues:           10,
    						HandSize:         2,
    						QueueLengthLimit: 10,
    					},
    				},
    			},
    		},
    	}
    	cfgObjs = append(cfgObjs, fsObj, plcObj)
    
    	clientset := clientsetfake.NewSimpleClientset(cfgObjs...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  4. 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)
  5. pkg/apis/flowcontrol/v1beta3/defaults_test.go

    							Queuing: &flowcontrolv1beta3.QueuingConfiguration{
    								HandSize:         PriorityLevelConfigurationDefaultHandSize,
    								Queues:           PriorityLevelConfigurationDefaultQueues,
    								QueueLengthLimit: PriorityLevelConfigurationDefaultQueueLengthLimit,
    							},
    						},
    					},
    				},
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  6. 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)
  7. pkg/apis/flowcontrol/v1beta3/zz_generated.conversion.go

    	out.Queues = in.Queues
    	out.HandSize = in.HandSize
    	out.QueueLengthLimit = in.QueueLengthLimit
    	return nil
    }
    
    // Convert_v1beta3_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:41 UTC 2023
    - 53.1K bytes
    - Viewed (0)
  8. pkg/apis/flowcontrol/v1/zz_generated.conversion.go

    	out.Queues = in.Queues
    	out.HandSize = in.HandSize
    	out.QueueLengthLimit = in.QueueLengthLimit
    	return nil
    }
    
    // Convert_v1_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:41 UTC 2023
    - 52.4K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top