1
- From 3198c607c243bd4363eadc7d9223e3a743f85215 Mon Sep 17 00:00:00 2001
1
+ From 16262f01a972ef4f2f88c5953e8114106e834351 Mon Sep 17 00:00:00 2001
2
2
From: Konstantinos Tsakalozos <
[email protected] >
3
3
Date: Wed, 3 Mar 2021 18:19:37 +0200
4
4
Subject: [PATCH] Kubelite integration
@@ -19,10 +19,10 @@ Subject: [PATCH] Kubelite integration
19
19
create mode 100644 cmd/kubelite/kubelite.go
20
20
21
21
diff --git a/cmd/kube-apiserver/app/server.go b/cmd/kube-apiserver/app/server.go
22
- index 411567a4175..a871cc9c975 100644
22
+ index 0887d9124ba..c7ece2136a1 100644
23
23
--- a/cmd/kube-apiserver/app/server.go
24
24
+++ b/cmd/kube-apiserver/app/server.go
25
- @@ -96 ,7 +96 ,7 @@ func checkNonZeroInsecurePort(fs *pflag.FlagSet) error {
25
+ @@ -86 ,7 +86 ,7 @@ func init() {
26
26
}
27
27
28
28
// NewAPIServerCommand creates a *cobra.Command object with default parameters
@@ -31,7 +31,7 @@ index 411567a4175..a871cc9c975 100644
31
31
s := options.NewServerRunOptions()
32
32
cmd := &cobra.Command{
33
33
Use: "kube-apiserver",
34
- @@ -138 ,8 +138 ,11 @@ cluster's shared state through which all other components interact.`,
34
+ @@ -124 ,8 +124 ,11 @@ cluster's shared state through which all other components interact.`,
35
35
if errs := completedOptions.Validate(); len(errs) != 0 {
36
36
return utilerrors.NewAggregate(errs)
37
37
}
@@ -46,10 +46,10 @@ index 411567a4175..a871cc9c975 100644
46
46
Args: func(cmd *cobra.Command, args []string) error {
47
47
for _, arg := range args {
48
48
diff --git a/cmd/kube-scheduler/app/server.go b/cmd/kube-scheduler/app/server.go
49
- index b65f4e74d09..0885de22da1 100644
49
+ index e6bda61b6e6..049b52fefaa 100644
50
50
--- a/cmd/kube-scheduler/app/server.go
51
51
+++ b/cmd/kube-scheduler/app/server.go
52
- @@ -120 ,7 +120 ,11 @@ func runCommand(cmd *cobra.Command, opts *options.Options, registryOptions ...Op
52
+ @@ -128 ,7 +128 ,11 @@ func runCommand(cmd *cobra.Command, opts *options.Options, registryOptions ...Op
53
53
ctx, cancel := context.WithCancel(context.Background())
54
54
defer cancel()
55
55
go func() {
@@ -63,10 +63,10 @@ index b65f4e74d09..0885de22da1 100644
63
63
cancel()
64
64
}()
65
65
diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go
66
- index 43dfd8d4f45..015a3df23f3 100644
66
+ index 86c73b030d5..efeb017e92f 100644
67
67
--- a/cmd/kubelet/app/server.go
68
68
+++ b/cmd/kubelet/app/server.go
69
- @@ -112 ,7 +112 ,7 @@ const (
69
+ @@ -114 ,7 +114 ,7 @@ const (
70
70
)
71
71
72
72
// NewKubeletCommand creates a *cobra.Command object with default parameters
@@ -75,7 +75,7 @@ index 43dfd8d4f45..015a3df23f3 100644
75
75
cleanFlagSet := pflag.NewFlagSet(componentKubelet, pflag.ContinueOnError)
76
76
cleanFlagSet.SetNormalizeFunc(cliflag.WordSepNormalizeFunc)
77
77
kubeletFlags := options.NewKubeletFlags()
78
- @@ -287 ,7 +287 ,12 @@ HTTP server: The kubelet can also listen for HTTP and respond to a simple API
78
+ @@ -253 ,7 +253 ,12 @@ HTTP server: The kubelet can also listen for HTTP and respond to a simple API
79
79
klog.ErrorS(err, "kubelet running with insufficient permissions")
80
80
}
81
81
// set up signal context here in order to be reused by kubelet and docker shim
@@ -89,15 +89,15 @@ index 43dfd8d4f45..015a3df23f3 100644
89
89
90
90
// make the kubelet's config safe for logging
91
91
config := kubeletServer.KubeletConfiguration.DeepCopy()
92
- @@ -298 ,7 +303 ,7 @@ HTTP server: The kubelet can also listen for HTTP and respond to a simple API
92
+ @@ -264 ,7 +269 ,7 @@ HTTP server: The kubelet can also listen for HTTP and respond to a simple API
93
93
klog.V(5).InfoS("KubeletConfiguration", "configuration", config)
94
94
95
95
// run the kubelet
96
- - if err := Run(ctx, kubeletServer, kubeletDeps, utilfeature.DefaultFeatureGate); err != nil {
97
- + if err := Run(runctx, kubeletServer, kubeletDeps, utilfeature.DefaultFeatureGate); err != nil {
98
- klog.ErrorS(err, "Failed to run kubelet")
99
- os.Exit(1)
100
- }
96
+ - return Run(ctx, kubeletServer, kubeletDeps, utilfeature.DefaultFeatureGate)
97
+ + return Run(runctx, kubeletServer, kubeletDeps, utilfeature.DefaultFeatureGate)
98
+ },
99
+ }
100
+
101
101
diff --git a/cmd/kubelite/app/daemons/daemon.go b/cmd/kubelite/app/daemons/daemon.go
102
102
new file mode 100644
103
103
index 00000000000..dbef03cf07e
@@ -394,7 +394,7 @@ index 00000000000..667b24f68e6
394
394
+ println("Stopping kubelite")
395
395
+ }
396
396
diff --git a/pkg/volume/csi/csi_plugin.go b/pkg/volume/csi/csi_plugin.go
397
- index 0ae6d084f0e..f27f9e1b812 100644
397
+ index 3b0a5773e58..6da5e3d4ea1 100644
398
398
--- a/pkg/volume/csi/csi_plugin.go
399
399
+++ b/pkg/volume/csi/csi_plugin.go
400
400
@@ -243,20 +243,24 @@ func (p *csiPlugin) Init(host volume.VolumeHost) error {
0 commit comments