resume starts the controller to process events
(ctx context.Context)
| 93 | |
| 94 | // resume starts the controller to process events |
| 95 | func (c *Controller) resume(ctx context.Context) error { |
| 96 | namespaces, err := c.clusterStore.ListNamespace(ctx) |
| 97 | if err != nil { |
| 98 | return fmt.Errorf("failed to list namespaces: %w", err) |
| 99 | } |
| 100 | for _, ns := range namespaces { |
| 101 | clusters, err := c.clusterStore.ListCluster(ctx, ns) |
| 102 | if err != nil { |
| 103 | return fmt.Errorf("failed to list clusters: %w", err) |
| 104 | } |
| 105 | for _, cluster := range clusters { |
| 106 | c.addCluster(ns, cluster) |
| 107 | logger.Get().Debug("Resume the cluster", zap.String("namespace", ns), zap.String("cluster", cluster)) |
| 108 | } |
| 109 | } |
| 110 | return nil |
| 111 | } |
| 112 | |
| 113 | func (c *Controller) becomeLeader(ctx context.Context, prevTermLeader string) { |
| 114 | if prevTermLeader == c.clusterStore.ID() { |
no test coverage detected