Reset clusterHealth when autopilot starts
This commit is contained in:
parent
504b55e370
commit
0e76d62846
|
@ -64,6 +64,7 @@ func NewAutopilot(logger *log.Logger, delegate Delegate, interval, healthInterva
|
||||||
func (a *Autopilot) Start() {
|
func (a *Autopilot) Start() {
|
||||||
a.shutdownCh = make(chan struct{})
|
a.shutdownCh = make(chan struct{})
|
||||||
a.waitGroup = sync.WaitGroup{}
|
a.waitGroup = sync.WaitGroup{}
|
||||||
|
a.clusterHealth = OperatorHealthReply{}
|
||||||
|
|
||||||
a.waitGroup.Add(2)
|
a.waitGroup.Add(2)
|
||||||
go a.run()
|
go a.run()
|
||||||
|
|
Loading…
Reference in New Issue