(ctx context.Context, prevTermLeader string)
| 111 | } |
| 112 | |
| 113 | func (c *Controller) becomeLeader(ctx context.Context, prevTermLeader string) { |
| 114 | if prevTermLeader == c.clusterStore.ID() { |
| 115 | return |
| 116 | } |
| 117 | if err := c.resume(ctx); err != nil { |
| 118 | logger.Get().Error("Failed to resume the controller", zap.Error(err)) |
| 119 | return |
| 120 | } |
| 121 | logger.Get().Info("Became the leader, resume the controller") |
| 122 | } |
| 123 | |
| 124 | func (c *Controller) syncLoop(ctx context.Context) { |
| 125 | defer c.wg.Done() |