commit
4e4ec8b9b4
2 changed files with 4 additions and 4 deletions
|
@ -251,7 +251,7 @@ type NGINXController struct {
|
||||||
|
|
||||||
// Start starts a new NGINX master process running in the foreground.
|
// Start starts a new NGINX master process running in the foreground.
|
||||||
func (n *NGINXController) Start() {
|
func (n *NGINXController) Start() {
|
||||||
glog.Infof("Starting NGINX Ingress controller")
|
glog.Info("Starting NGINX Ingress controller")
|
||||||
|
|
||||||
n.store.Run(n.stopCh)
|
n.store.Run(n.stopCh)
|
||||||
|
|
||||||
|
@ -336,7 +336,7 @@ func (n *NGINXController) Stop() error {
|
||||||
return fmt.Errorf("shutdown already in progress")
|
return fmt.Errorf("shutdown already in progress")
|
||||||
}
|
}
|
||||||
|
|
||||||
glog.Infof("Shutting down controller queues")
|
glog.Info("Shutting down controller queues")
|
||||||
close(n.stopCh)
|
close(n.stopCh)
|
||||||
go n.syncQueue.Shutdown()
|
go n.syncQueue.Shutdown()
|
||||||
if n.syncStatus != nil {
|
if n.syncStatus != nil {
|
||||||
|
|
|
@ -136,7 +136,7 @@ func (s statusSync) Run() {
|
||||||
}, stopCh)
|
}, stopCh)
|
||||||
},
|
},
|
||||||
OnStoppedLeading: func() {
|
OnStoppedLeading: func() {
|
||||||
glog.V(2).Infof("I am not status update leader anymore")
|
glog.V(2).Info("I am not status update leader anymore")
|
||||||
close(stopCh)
|
close(stopCh)
|
||||||
|
|
||||||
// cancel the context
|
// cancel the context
|
||||||
|
@ -197,7 +197,7 @@ func (s statusSync) Shutdown() {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
glog.Infof("updating status of Ingress rules (remove)")
|
glog.Info("updating status of Ingress rules (remove)")
|
||||||
|
|
||||||
addrs, err := s.runningAddresses()
|
addrs, err := s.runningAddresses()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Loading…
Reference in a new issue