mirror of
https://github.com/kubernetes/client-go.git
synced 2026-02-21 23:53:16 +00:00
81 lines
3.8 KiB
Go
81 lines
3.8 KiB
Go
/*
|
|
Copyright The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
// Code generated by applyconfiguration-gen. DO NOT EDIT.
|
|
|
|
package v1beta2
|
|
|
|
// QueuingConfigurationApplyConfiguration represents a declarative configuration of the QueuingConfiguration type for use
|
|
// with apply.
|
|
//
|
|
// QueuingConfiguration holds the configuration parameters for queuing
|
|
type QueuingConfigurationApplyConfiguration struct {
|
|
// `queues` is the number of queues for this priority level. The
|
|
// queues exist independently at each apiserver. The value must be
|
|
// positive. Setting it to 1 effectively precludes
|
|
// shufflesharding and thus makes the distinguisher method of
|
|
// associated flow schemas irrelevant. This field has a default
|
|
// value of 64.
|
|
Queues *int32 `json:"queues,omitempty"`
|
|
// `handSize` is a small positive number that configures the
|
|
// shuffle sharding of requests into queues. When enqueuing a request
|
|
// at this priority level the request's flow identifier (a string
|
|
// pair) is hashed and the hash value is used to shuffle the list
|
|
// of queues and deal a hand of the size specified here. The
|
|
// request is put into one of the shortest queues in that hand.
|
|
// `handSize` must be no larger than `queues`, and should be
|
|
// significantly smaller (so that a few heavy flows do not
|
|
// saturate most of the queues). See the user-facing
|
|
// documentation for more extensive guidance on setting this
|
|
// field. This field has a default value of 8.
|
|
HandSize *int32 `json:"handSize,omitempty"`
|
|
// `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.
|
|
QueueLengthLimit *int32 `json:"queueLengthLimit,omitempty"`
|
|
}
|
|
|
|
// QueuingConfigurationApplyConfiguration constructs a declarative configuration of the QueuingConfiguration type for use with
|
|
// apply.
|
|
func QueuingConfiguration() *QueuingConfigurationApplyConfiguration {
|
|
return &QueuingConfigurationApplyConfiguration{}
|
|
}
|
|
|
|
// WithQueues sets the Queues field in the declarative configuration to the given value
|
|
// and returns the receiver, so that objects can be built by chaining "With" function invocations.
|
|
// If called multiple times, the Queues field is set to the value of the last call.
|
|
func (b *QueuingConfigurationApplyConfiguration) WithQueues(value int32) *QueuingConfigurationApplyConfiguration {
|
|
b.Queues = &value
|
|
return b
|
|
}
|
|
|
|
// WithHandSize sets the HandSize field in the declarative configuration to the given value
|
|
// and returns the receiver, so that objects can be built by chaining "With" function invocations.
|
|
// If called multiple times, the HandSize field is set to the value of the last call.
|
|
func (b *QueuingConfigurationApplyConfiguration) WithHandSize(value int32) *QueuingConfigurationApplyConfiguration {
|
|
b.HandSize = &value
|
|
return b
|
|
}
|
|
|
|
// WithQueueLengthLimit sets the QueueLengthLimit field in the declarative configuration to the given value
|
|
// and returns the receiver, so that objects can be built by chaining "With" function invocations.
|
|
// If called multiple times, the QueueLengthLimit field is set to the value of the last call.
|
|
func (b *QueuingConfigurationApplyConfiguration) WithQueueLengthLimit(value int32) *QueuingConfigurationApplyConfiguration {
|
|
b.QueueLengthLimit = &value
|
|
return b
|
|
}
|