1- From 3198c607c243bd4363eadc7d9223e3a743f85215 Mon Sep 17 00:00:00 2001
1+ From 16262f01a972ef4f2f88c5953e8114106e834351 Mon Sep 17 00:00:00 2001
22From: Konstantinos Tsakalozos <
[email protected] >
33Date: Wed, 3 Mar 2021 18:19:37 +0200
44Subject: [PATCH] Kubelite integration
@@ -19,10 +19,10 @@ Subject: [PATCH] Kubelite integration
1919 create mode 100644 cmd/kubelite/kubelite.go
2020
2121diff --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
2323--- a/cmd/kube-apiserver/app/server.go
2424+++ 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() {
2626 }
2727
2828 // NewAPIServerCommand creates a *cobra.Command object with default parameters
@@ -31,7 +31,7 @@ index 411567a4175..a871cc9c975 100644
3131 s := options.NewServerRunOptions()
3232 cmd := &cobra.Command{
3333 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.`,
3535 if errs := completedOptions.Validate(); len(errs) != 0 {
3636 return utilerrors.NewAggregate(errs)
3737 }
@@ -46,10 +46,10 @@ index 411567a4175..a871cc9c975 100644
4646 Args: func(cmd *cobra.Command, args []string) error {
4747 for _, arg := range args {
4848diff --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
5050--- a/cmd/kube-scheduler/app/server.go
5151+++ 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
5353 ctx, cancel := context.WithCancel(context.Background())
5454 defer cancel()
5555 go func() {
@@ -63,10 +63,10 @@ index b65f4e74d09..0885de22da1 100644
6363 cancel()
6464 }()
6565diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go
66- index 43dfd8d4f45..015a3df23f3 100644
66+ index 86c73b030d5..efeb017e92f 100644
6767--- a/cmd/kubelet/app/server.go
6868+++ b/cmd/kubelet/app/server.go
69- @@ -112 ,7 +112 ,7 @@ const (
69+ @@ -114 ,7 +114 ,7 @@ const (
7070 )
7171
7272 // NewKubeletCommand creates a *cobra.Command object with default parameters
@@ -75,7 +75,7 @@ index 43dfd8d4f45..015a3df23f3 100644
7575 cleanFlagSet := pflag.NewFlagSet(componentKubelet, pflag.ContinueOnError)
7676 cleanFlagSet.SetNormalizeFunc(cliflag.WordSepNormalizeFunc)
7777 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
7979 klog.ErrorS(err, "kubelet running with insufficient permissions")
8080 }
8181 // set up signal context here in order to be reused by kubelet and docker shim
@@ -89,15 +89,15 @@ index 43dfd8d4f45..015a3df23f3 100644
8989
9090 // make the kubelet's config safe for logging
9191 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
9393 klog.V(5).InfoS("KubeletConfiguration", "configuration", config)
9494
9595 // 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+
101101diff --git a/cmd/kubelite/app/daemons/daemon.go b/cmd/kubelite/app/daemons/daemon.go
102102new file mode 100644
103103index 00000000000..dbef03cf07e
@@ -394,7 +394,7 @@ index 00000000000..667b24f68e6
394394+ println("Stopping kubelite")
395395+ }
396396diff --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
398398--- a/pkg/volume/csi/csi_plugin.go
399399+++ b/pkg/volume/csi/csi_plugin.go
400400@@ -243,20 +243,24 @@ func (p *csiPlugin) Init(host volume.VolumeHost) error {
0 commit comments