github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 02:41:25 +00:00
Code Issues Projects Releases Wiki Activity

Bump QPS limits for Kubelet

Browse Source
This commit is contained in:
Wojciech Tyczyński 2023-02-28 09:30:52 +01:00
parent 931e07de16
commit 760acbbbe3
3 changed files with 26 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kubelet/apis/config/v1beta1/defaults.go
View File

@ -96,10 +96,10 @@ func SetDefaults_KubeletConfiguration(obj *kubeletconfigv1beta1.KubeletConfigura
obj.RegistryBurst = 10 obj.RegistryBurst = 10
} }
if obj.EventRecordQPS == nil { if obj.EventRecordQPS == nil {
obj.EventRecordQPS = utilpointer.Int32(5) obj.EventRecordQPS = utilpointer.Int32(50)
} }
if obj.EventBurst == 0 { if obj.EventBurst == 0 {
obj.EventBurst = 10 obj.EventBurst = 100
} }
if obj.EnableDebuggingHandlers == nil { if obj.EnableDebuggingHandlers == nil {
obj.EnableDebuggingHandlers = utilpointer.Bool(true) obj.EnableDebuggingHandlers = utilpointer.Bool(true)
@ -200,10 +200,10 @@ func SetDefaults_KubeletConfiguration(obj *kubeletconfigv1beta1.KubeletConfigura
obj.ContentType = "application/vnd.kubernetes.protobuf" obj.ContentType = "application/vnd.kubernetes.protobuf"
} }
if obj.KubeAPIQPS == nil { if obj.KubeAPIQPS == nil {
obj.KubeAPIQPS = utilpointer.Int32(5) obj.KubeAPIQPS = utilpointer.Int32(50)
} }
if obj.KubeAPIBurst == 0 { if obj.KubeAPIBurst == 0 {
obj.KubeAPIBurst = 10 obj.KubeAPIBurst = 100
} }
if obj.SerializeImagePulls == nil { if obj.SerializeImagePulls == nil {
// SerializeImagePulls is default to true when MaxParallelImagePulls // SerializeImagePulls is default to true when MaxParallelImagePulls

36
pkg/kubelet/apis/config/v1beta1/defaults_test.go
View File

@ -65,8 +65,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
}, },
RegistryPullQPS: utilpointer.Int32(5), RegistryPullQPS: utilpointer.Int32(5),
RegistryBurst: 10, RegistryBurst: 10,
EventRecordQPS: utilpointer.Int32(5), EventRecordQPS: utilpointer.Int32(50),
EventBurst: 10, EventBurst: 100,
EnableDebuggingHandlers: utilpointer.Bool(true), EnableDebuggingHandlers: utilpointer.Bool(true),
HealthzPort: utilpointer.Int32(10248), HealthzPort: utilpointer.Int32(10248),
HealthzBindAddress: "127.0.0.1", HealthzBindAddress: "127.0.0.1",
@ -97,8 +97,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
NodeStatusMaxImages: utilpointer.Int32(50), NodeStatusMaxImages: utilpointer.Int32(50),
MaxOpenFiles: 1000000, MaxOpenFiles: 1000000,
ContentType: "application/vnd.kubernetes.protobuf", ContentType: "application/vnd.kubernetes.protobuf",
KubeAPIQPS: utilpointer.Int32(5), KubeAPIQPS: utilpointer.Int32(50),
KubeAPIBurst: 10, KubeAPIBurst: 100,
SerializeImagePulls: utilpointer.Bool(true), SerializeImagePulls: utilpointer.Bool(true),
MaxParallelImagePulls: nil, MaxParallelImagePulls: nil,
EvictionHard: nil, EvictionHard: nil,
@ -279,7 +279,7 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
RegistryPullQPS: utilpointer.Int32(0), RegistryPullQPS: utilpointer.Int32(0),
RegistryBurst: 10, RegistryBurst: 10,
EventRecordQPS: utilpointer.Int32(0), EventRecordQPS: utilpointer.Int32(0),
EventBurst: 10, EventBurst: 100,
EnableDebuggingHandlers: utilpointer.Bool(false), EnableDebuggingHandlers: utilpointer.Bool(false),
HealthzPort: utilpointer.Int32(0), HealthzPort: utilpointer.Int32(0),
HealthzBindAddress: "127.0.0.1", HealthzBindAddress: "127.0.0.1",
@ -314,7 +314,7 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
MaxOpenFiles: 1000000, MaxOpenFiles: 1000000,
ContentType: "application/vnd.kubernetes.protobuf", ContentType: "application/vnd.kubernetes.protobuf",
KubeAPIQPS: utilpointer.Int32(0), KubeAPIQPS: utilpointer.Int32(0),
KubeAPIBurst: 10, KubeAPIBurst: 100,
SerializeImagePulls: utilpointer.Bool(false), SerializeImagePulls: utilpointer.Bool(false),
MaxParallelImagePulls: nil, MaxParallelImagePulls: nil,
EvictionHard: map[string]string{}, EvictionHard: map[string]string{},
@ -674,8 +674,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
}, },
RegistryPullQPS: utilpointer.Int32(5), RegistryPullQPS: utilpointer.Int32(5),
RegistryBurst: 10, RegistryBurst: 10,
EventRecordQPS: utilpointer.Int32(5), EventRecordQPS: utilpointer.Int32(50),
EventBurst: 10, EventBurst: 100,
EnableDebuggingHandlers: utilpointer.Bool(true), EnableDebuggingHandlers: utilpointer.Bool(true),
HealthzPort: utilpointer.Int32(10248), HealthzPort: utilpointer.Int32(10248),
HealthzBindAddress: "127.0.0.1", HealthzBindAddress: "127.0.0.1",
@ -706,8 +706,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
NodeStatusMaxImages: utilpointer.Int32(50), NodeStatusMaxImages: utilpointer.Int32(50),
MaxOpenFiles: 1000000, MaxOpenFiles: 1000000,
ContentType: "application/vnd.kubernetes.protobuf", ContentType: "application/vnd.kubernetes.protobuf",
KubeAPIQPS: utilpointer.Int32(5), KubeAPIQPS: utilpointer.Int32(50),
KubeAPIBurst: 10, KubeAPIBurst: 100,
SerializeImagePulls: utilpointer.Bool(true), SerializeImagePulls: utilpointer.Bool(true),
MaxParallelImagePulls: nil, MaxParallelImagePulls: nil,
EvictionHard: nil, EvictionHard: nil,
@ -763,8 +763,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
}, },
RegistryPullQPS: utilpointer.Int32Ptr(5), RegistryPullQPS: utilpointer.Int32Ptr(5),
RegistryBurst: 10, RegistryBurst: 10,
EventRecordQPS: utilpointer.Int32Ptr(5), EventRecordQPS: utilpointer.Int32Ptr(50),
EventBurst: 10, EventBurst: 100,
EnableDebuggingHandlers: utilpointer.Bool(true), EnableDebuggingHandlers: utilpointer.Bool(true),
HealthzPort: utilpointer.Int32Ptr(10248), HealthzPort: utilpointer.Int32Ptr(10248),
HealthzBindAddress: "127.0.0.1", HealthzBindAddress: "127.0.0.1",
@ -795,8 +795,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
NodeStatusMaxImages: utilpointer.Int32Ptr(50), NodeStatusMaxImages: utilpointer.Int32Ptr(50),
MaxOpenFiles: 1000000, MaxOpenFiles: 1000000,
ContentType: "application/vnd.kubernetes.protobuf", ContentType: "application/vnd.kubernetes.protobuf",
KubeAPIQPS: utilpointer.Int32Ptr(5), KubeAPIQPS: utilpointer.Int32Ptr(50),
KubeAPIBurst: 10, KubeAPIBurst: 100,
SerializeImagePulls: utilpointer.Bool(false), SerializeImagePulls: utilpointer.Bool(false),
MaxParallelImagePulls: utilpointer.Int32(5), MaxParallelImagePulls: utilpointer.Int32(5),
EvictionHard: nil, EvictionHard: nil,
@ -852,8 +852,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
}, },
RegistryPullQPS: utilpointer.Int32Ptr(5), RegistryPullQPS: utilpointer.Int32Ptr(5),
RegistryBurst: 10, RegistryBurst: 10,
EventRecordQPS: utilpointer.Int32Ptr(5), EventRecordQPS: utilpointer.Int32Ptr(50),
EventBurst: 10, EventBurst: 100,
EnableDebuggingHandlers: utilpointer.Bool(true), EnableDebuggingHandlers: utilpointer.Bool(true),
HealthzPort: utilpointer.Int32Ptr(10248), HealthzPort: utilpointer.Int32Ptr(10248),
HealthzBindAddress: "127.0.0.1", HealthzBindAddress: "127.0.0.1",
@ -884,8 +884,8 @@ func TestSetDefaultsKubeletConfiguration(t *testing.T) {
NodeStatusMaxImages: utilpointer.Int32Ptr(50), NodeStatusMaxImages: utilpointer.Int32Ptr(50),
MaxOpenFiles: 1000000, MaxOpenFiles: 1000000,
ContentType: "application/vnd.kubernetes.protobuf", ContentType: "application/vnd.kubernetes.protobuf",
KubeAPIQPS: utilpointer.Int32Ptr(5), KubeAPIQPS: utilpointer.Int32Ptr(50),
KubeAPIBurst: 10, KubeAPIBurst: 100,
SerializeImagePulls: utilpointer.Bool(true), SerializeImagePulls: utilpointer.Bool(true),
MaxParallelImagePulls: utilpointer.Int32(1), MaxParallelImagePulls: utilpointer.Int32(1),
EvictionHard: nil, EvictionHard: nil,

8
staging/src/k8s.io/kubelet/config/v1beta1/types.go
View File

@ -205,14 +205,14 @@ type KubeletConfiguration struct {
RegistryBurst int32 `json:"registryBurst,omitempty"` RegistryBurst int32 `json:"registryBurst,omitempty"`
// eventRecordQPS is the maximum event creations per second. If 0, there // eventRecordQPS is the maximum event creations per second. If 0, there
// is no limit enforced. The value cannot be a negative number. // is no limit enforced. The value cannot be a negative number.
// Default: 5 // Default: 50
// +optional // +optional
EventRecordQPS *int32 `json:"eventRecordQPS,omitempty"` EventRecordQPS *int32 `json:"eventRecordQPS,omitempty"`
// eventBurst is the maximum size of a burst of event creations, temporarily // eventBurst is the maximum size of a burst of event creations, temporarily
// allows event creations to burst to this number, while still not exceeding // allows event creations to burst to this number, while still not exceeding
// eventRecordQPS. This field canot be a negative number and it is only used // eventRecordQPS. This field canot be a negative number and it is only used
// when eventRecordQPS > 0. // when eventRecordQPS > 0.
// Default: 10 // Default: 100
// +optional // +optional
EventBurst int32 `json:"eventBurst,omitempty"` EventBurst int32 `json:"eventBurst,omitempty"`
// enableDebuggingHandlers enables server endpoints for log access // enableDebuggingHandlers enables server endpoints for log access
@ -467,12 +467,12 @@ type KubeletConfiguration struct {
// +optional // +optional
ContentType string `json:"contentType,omitempty"` ContentType string `json:"contentType,omitempty"`
// kubeAPIQPS is the QPS to use while talking with kubernetes apiserver. // kubeAPIQPS is the QPS to use while talking with kubernetes apiserver.
// Default: 5 // Default: 50
// +optional // +optional
KubeAPIQPS *int32 `json:"kubeAPIQPS,omitempty"` KubeAPIQPS *int32 `json:"kubeAPIQPS,omitempty"`
// kubeAPIBurst is the burst to allow while talking with kubernetes API server. // kubeAPIBurst is the burst to allow while talking with kubernetes API server.
// This field cannot be a negative number. // This field cannot be a negative number.
// Default: 10 // Default: 100
// +optional // +optional
KubeAPIBurst int32 `json:"kubeAPIBurst,omitempty"` KubeAPIBurst int32 `json:"kubeAPIBurst,omitempty"`
// serializeImagePulls when enabled, tells the Kubelet to pull images one // serializeImagePulls when enabled, tells the Kubelet to pull images one