Skip to content

Commit b2aab98

Browse files
committed
flags(ingress): enable ingressv1, flip flag semantics
As requested in review [1] [1] Kong#826 (comment)
1 parent 8795634 commit b2aab98

File tree

3 files changed

+28
-33
lines changed

3 files changed

+28
-33
lines changed

cli/ingress-controller/flag_test.go

+12-17
Original file line numberDiff line numberDiff line change
@@ -133,9 +133,6 @@ func TestDefaults(t *testing.T) {
133133
LogLevel: "info",
134134
LogFormat: "text",
135135

136-
AllowIngressExtensionsV1beta1: true,
137-
AllowIngressNetworkingV1beta1: true,
138-
139136
EnableProfiling: true,
140137

141138
ShowVersion: false,
@@ -185,9 +182,9 @@ func TestOverrideViaCLIFlags(t *testing.T) {
185182
"--apiserver-host", "kube-apiserver.internal",
186183
"--kubeconfig", "/path/to/kubeconfig",
187184

188-
"--allow-ingress-extensionsv1beta1=false",
189-
"--allow-ingress-networkingv1beta1=false",
190-
"--allow-ingress-networkingv1=true",
185+
"--disable-ingress-extensionsv1beta1",
186+
"--disable-ingress-networkingv1beta1",
187+
"--disable-ingress-networkingv1",
191188

192189
"--log-format", "json",
193190

@@ -228,7 +225,9 @@ func TestOverrideViaCLIFlags(t *testing.T) {
228225
APIServerHost: "kube-apiserver.internal",
229226
KubeConfigFilePath: "/path/to/kubeconfig",
230227

231-
AllowIngressNetworkingV1: true,
228+
DisableIngressNetworkingV1: true,
229+
DisableIngressNetworkingV1beta1: true,
230+
DisableIngressExtensionsV1beta1: true,
232231

233232
LogLevel: "info",
234233
LogFormat: "json",
@@ -261,9 +260,9 @@ func TestOverrideViaEnvVars(t *testing.T) {
261260

262261
"CONTROLLER_KONG_CUSTOM_ENTITIES_SECRET": "foons/barsecretname",
263262

264-
"CONTROLLER_ALLOW_INGRESS_EXTENSIONSV1BETA1": "false",
265-
"CONTROLLER_ALLOW_INGRESS_NETWORKINGV1BETA1": "false",
266-
"CONTROLLER_ALLOW_INGRESS_NETWORKINGV1": "true",
263+
"CONTROLLER_DISABLE_INGRESS_EXTENSIONSV1BETA1": "true",
264+
"CONTROLLER_DISABLE_INGRESS_NETWORKINGV1BETA1": "true",
265+
"CONTROLLER_DISABLE_INGRESS_NETWORKINGV1": "true",
267266
}
268267
for k, v := range envs {
269268
os.Setenv(k, v)
@@ -303,7 +302,9 @@ func TestOverrideViaEnvVars(t *testing.T) {
303302
APIServerHost: "",
304303
KubeConfigFilePath: "",
305304

306-
AllowIngressNetworkingV1: true,
305+
DisableIngressNetworkingV1: true,
306+
DisableIngressNetworkingV1beta1: true,
307+
DisableIngressExtensionsV1beta1: true,
307308

308309
LogLevel: "panic",
309310
LogFormat: "text",
@@ -364,9 +365,6 @@ func TestDeprecatedFlags(t *testing.T) {
364365
APIServerHost: "",
365366
KubeConfigFilePath: "",
366367

367-
AllowIngressExtensionsV1beta1: true,
368-
AllowIngressNetworkingV1beta1: true,
369-
370368
LogLevel: "info",
371369
LogFormat: "text",
372370

@@ -431,9 +429,6 @@ func TestDeprecatedFlagPrecedences(t *testing.T) {
431429
APIServerHost: "",
432430
KubeConfigFilePath: "",
433431

434-
AllowIngressExtensionsV1beta1: true,
435-
AllowIngressNetworkingV1beta1: true,
436-
437432
LogLevel: "info",
438433
LogFormat: "text",
439434

cli/ingress-controller/flags.go

+13-13
Original file line numberDiff line numberDiff line change
@@ -84,9 +84,9 @@ type cliConfig struct {
8484
KubeConfigFilePath string
8585

8686
// Allowed Ingress resource versions
87-
AllowIngressExtensionsV1beta1 bool
88-
AllowIngressNetworkingV1beta1 bool
89-
AllowIngressNetworkingV1 bool
87+
DisableIngressExtensionsV1beta1 bool
88+
DisableIngressNetworkingV1beta1 bool
89+
DisableIngressNetworkingV1 bool
9090

9191
// Performance
9292
EnableProfiling bool
@@ -232,14 +232,14 @@ Kubernetes cluster and local discovery is attempted.`)
232232
"authorization and master location information.")
233233

234234
// Allowed Ingress resource versions
235-
flags.Bool("allow-ingress-extensionsv1beta1", true,
236-
`If disabled, the ingress controller won't try extensions/v1beta1 when negotiating the newest supported
235+
flags.Bool("disable-ingress-extensionsv1beta1", false,
236+
`If set, the ingress controller won't try extensions/v1beta1 when negotiating the newest supported
237237
Ingress API with Kubernetes.`)
238-
flags.Bool("allow-ingress-networkingv1beta1", true,
239-
`If disabled, the ingress controller won't try networking.k8s.io/v1beta1 when negotiating the newest supported
238+
flags.Bool("disable-ingress-networkingv1beta1", false,
239+
`If set, the ingress controller won't try networking.k8s.io/v1beta1 when negotiating the newest supported
240240
Ingress API with Kubernetes.`)
241-
flags.Bool("allow-ingress-networkingv1", false,
242-
`If disabled, the ingress controller won't try networking/v1 when negotiating the newest supported
241+
flags.Bool("disable-ingress-networkingv1", false,
242+
`If set, the ingress controller won't try networking/v1 when negotiating the newest supported
243243
Ingress API with Kubernetes.`)
244244

245245
// Misc
@@ -366,10 +366,10 @@ func parseFlags() (cliConfig, error) {
366366
config.APIServerHost = viper.GetString("apiserver-host")
367367
config.KubeConfigFilePath = viper.GetString("kubeconfig")
368368

369-
// Allowed Ingress resource versions
370-
config.AllowIngressExtensionsV1beta1 = viper.GetBool("allow-ingress-extensionsv1beta1")
371-
config.AllowIngressNetworkingV1beta1 = viper.GetBool("allow-ingress-networkingv1beta1")
372-
config.AllowIngressNetworkingV1 = viper.GetBool("allow-ingress-networkingv1")
369+
// Disabled Ingress resource versions
370+
config.DisableIngressExtensionsV1beta1 = viper.GetBool("disable-ingress-extensionsv1beta1")
371+
config.DisableIngressNetworkingV1beta1 = viper.GetBool("disable-ingress-networkingv1beta1")
372+
config.DisableIngressNetworkingV1 = viper.GetBool("disable-ingress-networkingv1")
373373

374374
// Misc
375375
config.EnableProfiling = viper.GetBool("profiling")

cli/ingress-controller/main.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -345,13 +345,13 @@ func main() {
345345
}
346346

347347
var preferredIngressAPIs []utils.IngressAPI
348-
if cliConfig.AllowIngressNetworkingV1 {
348+
if !cliConfig.DisableIngressNetworkingV1 {
349349
preferredIngressAPIs = append(preferredIngressAPIs, utils.NetworkingV1)
350350
}
351-
if cliConfig.AllowIngressNetworkingV1beta1 {
351+
if !cliConfig.DisableIngressNetworkingV1beta1 {
352352
preferredIngressAPIs = append(preferredIngressAPIs, utils.NetworkingV1beta1)
353353
}
354-
if cliConfig.AllowIngressExtensionsV1beta1 {
354+
if !cliConfig.DisableIngressExtensionsV1beta1 {
355355
preferredIngressAPIs = append(preferredIngressAPIs, utils.ExtensionsV1beta1)
356356
}
357357
controllerConfig.IngressAPI, err = utils.NegotiateResourceAPI(kubeClient, "Ingress", preferredIngressAPIs)

0 commit comments

Comments
 (0)