From 3483eb375e6a7c21b604bda6ece1215daf6a9a22 Mon Sep 17 00:00:00 2001 From: Manuel Alejandro de Brito Fontes Date: Fri, 11 Jan 2019 14:43:02 -0300 Subject: [PATCH] Remove flag sort-backends --- cmd/nginx/flags.go | 8 +++----- internal/ingress/controller/controller.go | 22 ---------------------- 2 files changed, 3 insertions(+), 27 deletions(-) diff --git a/cmd/nginx/flags.go b/cmd/nginx/flags.go index 096a39cde3..df5a8167ba 100644 --- a/cmd/nginx/flags.go +++ b/cmd/nginx/flags.go @@ -114,9 +114,6 @@ different namespace than their own. May be used together with watch-namespace.`) `Update the load-balancer status of Ingress objects when the controller shuts down. Requires the update-status parameter.`) - sortBackends = flags.Bool("sort-backends", false, - `Sort servers inside NGINX upstreams.`) - useNodeInternalIP = flags.Bool("report-node-internal-ip-address", false, `Set the load-balancer status of Ingress objects to internal Node addresses instead of external. Requires the update-status parameter.`) @@ -130,7 +127,7 @@ Requires the update-status parameter.`) annotationsPrefix = flags.String("annotations-prefix", "nginx.ingress.kubernetes.io", `Prefix of the Ingress annotations specific to the NGINX controller.`) - enableSSLChainCompletion = flags.Bool("enable-ssl-chain-completion", true, + enableSSLChainCompletion = flags.Bool("enable-ssl-chain-completion", false, `Autocomplete SSL certificate chains with missing intermediate CA certificates. A valid certificate chain is required to enable OCSP stapling. Certificates uploaded to Kubernetes must have the "Authority Information Access" X.509 v3 @@ -163,6 +160,8 @@ Feature backed by OpenResty Lua libraries. Requires that OCSP stapling is not en `Disable support for catch-all Ingresses`) ) + flags.MarkDeprecated("sort-backends", "Feature removed because of the lua load balancer that removed the need of reloads for change in endpoints") + flag.Set("logtostderr", "true") flags.AddGoFlagSet(flag.CommandLine) @@ -248,7 +247,6 @@ Feature backed by OpenResty Lua libraries. Requires that OCSP stapling is not en PublishStatusAddress: *publishStatusAddress, ForceNamespaceIsolation: *forceIsolation, UpdateStatusOnShutdown: *updateStatusOnShutdown, - SortBackends: *sortBackends, UseNodeInternalIP: *useNodeInternalIP, SyncRateLimit: *syncRateLimit, DynamicCertificatesEnabled: *dynamicCertificatesEnabled, diff --git a/internal/ingress/controller/controller.go b/internal/ingress/controller/controller.go index be0a1d9504..2522430b25 100644 --- a/internal/ingress/controller/controller.go +++ b/internal/ingress/controller/controller.go @@ -18,7 +18,6 @@ package controller import ( "fmt" - "math/rand" "sort" "strconv" "strings" @@ -79,8 +78,6 @@ type Configuration struct { ElectionID string UpdateStatusOnShutdown bool - SortBackends bool - ListenPorts *ngx_config.ListenPorts EnableSSLPassthrough bool @@ -845,17 +842,6 @@ func (n *NGINXController) serviceEndpoints(svcKey, backendPort string) ([]ingres klog.Warningf("Service %q does not have any active Endpoint.", svcKey) } - if n.cfg.SortBackends { - sort.SliceStable(endps, func(i, j int) bool { - iName := endps[i].Address - jName := endps[j].Address - if iName != jName { - return iName < jName - } - - return endps[i].Port < endps[j].Port - }) - } upstreams = append(upstreams, endps...) break } @@ -884,14 +870,6 @@ func (n *NGINXController) serviceEndpoints(svcKey, backendPort string) ([]ingres return upstreams, nil } - if !n.cfg.SortBackends { - rand.Seed(time.Now().UnixNano()) - for i := range upstreams { - j := rand.Intn(i + 1) - upstreams[i], upstreams[j] = upstreams[j], upstreams[i] - } - } - return upstreams, nil }