@@ -35,6 +35,7 @@ import (
35
35
"time"
36
36
37
37
"github.com/spf13/cobra"
38
+ "github.com/spf13/pflag"
38
39
39
40
"k8s.io/apimachinery/pkg/util/sets"
40
41
"k8s.io/apimachinery/pkg/util/wait"
@@ -47,17 +48,17 @@ import (
47
48
"k8s.io/kubernetes/cmd/cloud-controller-manager/app"
48
49
"k8s.io/kubernetes/cmd/cloud-controller-manager/app/options"
49
50
"k8s.io/kubernetes/pkg/features" // add the kubernetes feature gates
50
- utilflag "k8s.io/kubernetes/pkg/util/flag"
51
51
netutils "k8s.io/utils/net"
52
52
53
53
cloudprovider "k8s.io/cloud-provider"
54
54
awsv1 "k8s.io/cloud-provider-aws/pkg/providers/v1"
55
55
awsv2 "k8s.io/cloud-provider-aws/pkg/providers/v2"
56
56
57
+ cloudnodecontroller "k8s.io/cloud-provider/controllers/node"
58
+ cloudnodelifecyclecontroller "k8s.io/cloud-provider/controllers/nodelifecycle"
59
+ routecontroller "k8s.io/cloud-provider/controllers/route"
60
+ servicecontroller "k8s.io/cloud-provider/controllers/service"
57
61
cloudcontrollerconfig "k8s.io/kubernetes/cmd/cloud-controller-manager/app/config"
58
- cloudcontrollers "k8s.io/kubernetes/pkg/controller/cloud"
59
- routecontroller "k8s.io/kubernetes/pkg/controller/route"
60
- servicecontroller "k8s.io/kubernetes/pkg/controller/service"
61
62
)
62
63
63
64
const (
@@ -106,7 +107,7 @@ func main() {
106
107
}
107
108
}
108
109
109
- utilflag . PrintFlags (cmd .Flags ())
110
+ printFlags (cmd .Flags ())
110
111
111
112
c , err := s .Config (KnownControllers (), ControllersDisabledByDefault .List ())
112
113
if err != nil {
@@ -162,7 +163,7 @@ func newControllerInitializers() map[string]initFunc {
162
163
163
164
func startCloudNodeController (ctx * cloudcontrollerconfig.CompletedConfig , cloud cloudprovider.Interface , stopCh <- chan struct {}) (http.Handler , bool , error ) {
164
165
// Start the CloudNodeController
165
- nodeController , err := cloudcontrollers .NewCloudNodeController (
166
+ nodeController , err := cloudnodecontroller .NewCloudNodeController (
166
167
ctx .SharedInformers .Core ().V1 ().Nodes (),
167
168
// cloud node controller uses existing cluster role from node-controller
168
169
ctx .ClientBuilder .ClientOrDie ("node-controller" ),
@@ -181,7 +182,7 @@ func startCloudNodeController(ctx *cloudcontrollerconfig.CompletedConfig, cloud
181
182
182
183
func startCloudNodeLifecycleController (ctx * cloudcontrollerconfig.CompletedConfig , cloud cloudprovider.Interface , stopCh <- chan struct {}) (http.Handler , bool , error ) {
183
184
// Start the cloudNodeLifecycleController
184
- cloudNodeLifecycleController , err := cloudcontrollers .NewCloudNodeLifecycleController (
185
+ cloudNodeLifecycleController , err := cloudnodelifecyclecontroller .NewCloudNodeLifecycleController (
185
186
ctx .SharedInformers .Core ().V1 ().Nodes (),
186
187
// cloud node lifecycle controller uses existing cluster role from node-controller
187
188
ctx .ClientBuilder .ClientOrDie ("node-controller" ),
@@ -206,6 +207,7 @@ func startServiceController(ctx *cloudcontrollerconfig.CompletedConfig, cloud cl
206
207
ctx .SharedInformers .Core ().V1 ().Services (),
207
208
ctx .SharedInformers .Core ().V1 ().Nodes (),
208
209
ctx .ComponentConfig .KubeCloudShared .ClusterName ,
210
+ utilfeature .DefaultFeatureGate ,
209
211
)
210
212
if err != nil {
211
213
// This error shouldn't fail. It lives like this as a legacy.
@@ -282,3 +284,10 @@ func processCIDRs(cidrsList string) ([]*net.IPNet, bool, error) {
282
284
283
285
return cidrs , dualstack , nil
284
286
}
287
+
288
+ // PrintFlags logs the flags in the flagset
289
+ func printFlags (flags * pflag.FlagSet ) {
290
+ flags .VisitAll (func (flag * pflag.Flag ) {
291
+ klog .V (1 ).Infof ("FLAG: --%s=%q" , flag .Name , flag .Value )
292
+ })
293
+ }
0 commit comments