Add flag to skip the update of Ingress status on shutdown

core/pkg/ingress/controller/controller.go

@@ -140,6 +140,7 @@ type Configuration struct {
 
 	UpdateStatus           bool
 	ElectionID             string
+	UpdateStatusOnShutdown bool
 }
 
 // newIngressController creates an Ingress controller
@@ -313,6 +314,7 @@ func newIngressController(config *Configuration) *GenericController {
 			ElectionID:             config.ElectionID,
 			IngressClass:           config.IngressClass,
 			DefaultIngressClass:    config.DefaultIngressClass,
+			UpdateStatusOnShutdown: config.UpdateStatusOnShutdown,
 		})
 	} else {
 		glog.Warning("Update of ingress status is disabled (flag --update-status=false was specified)")

core/pkg/ingress/controller/launch.go

@@ -89,6 +89,10 @@ func NewIngressController(backend ingress.Controller) *GenericController {
 		forceIsolation = flags.Bool("force-namespace-isolation", false,
 			`Force namespace isolation. This flag is required to avoid the reference of secrets or 
 		configmaps located in a different namespace than the specified in the flag --watch-namespace.`)
+
+		UpdateStatusOnShutdown = flags.Bool("update-status-on-shutdown", true, `Indicates if the 
+		ingress controller should update the Ingress status IP/hostname when the controller 
+		is being stopped. Default is true`)
 	)
 
 	flags.AddGoFlagSet(flag.CommandLine)
@@ -164,6 +168,7 @@ func NewIngressController(backend ingress.Controller) *GenericController {
 		PublishService:          *publishSvc,
 		Backend:                 backend,
 		ForceNamespaceIsolation: *forceIsolation,
+		UpdateStatusOnShutdown:  *UpdateStatusOnShutdown,
 	}
 
 	ic := newIngressController(config)

core/pkg/ingress/status/status.go

@@ -55,8 +55,11 @@ type Config struct {
 	Client         clientset.Interface
 	PublishService string
 	IngressLister  store.IngressLister
+
 	ElectionID string
 
+	UpdateStatusOnShutdown bool
+
 	DefaultIngressClass string
 	IngressClass        string
 }
@@ -98,6 +101,11 @@ func (s statusSync) Shutdown() {
 		return
 	}
 
+	if !s.UpdateStatusOnShutdown {
+		glog.Warningf("skipping update of status of Ingress rules")
+		return
+	}
+
 	glog.Infof("updating status of Ingress rules (remove)")
 
 	addrs, err := s.runningAddresess()

core/pkg/ingress/status/status_test.go

@@ -265,6 +265,7 @@ func TestStatusActions(t *testing.T) {
 		IngressLister:          buildIngressListener(),
 		DefaultIngressClass:    "nginx",
 		IngressClass:           "",
+		UpdateStatusOnShutdown: true,
 	}
 	// create object
 	fkSync := NewStatusSyncer(c)