|
| 1 | +package steps |
| 2 | + |
| 3 | +import ( |
| 4 | + "context" |
| 5 | + "fmt" |
| 6 | + "strings" |
| 7 | + |
| 8 | + "k8s.io/component-base/featuregate" |
| 9 | +) |
| 10 | + |
| 11 | +// catalogdHAFeature gates scenarios that require a multi-node cluster. |
| 12 | +// It is set to true in BeforeSuite when the cluster has at least 2 nodes, |
| 13 | +// which is the case for the experimental e2e suite (kind-config-2node.yaml) |
| 14 | +// but not the standard suite. |
| 15 | +const catalogdHAFeature featuregate.Feature = "CatalogdHA" |
| 16 | + |
| 17 | +// CatalogdLeaderPodIsForceDeleted force-deletes the catalogd leader pod to simulate leader loss. |
| 18 | +// The pod is identified from sc.leaderPods["catalogd"] (populated by a prior |
| 19 | +// "catalogd is ready to reconcile resources" step). Force-deletion is equivalent to |
| 20 | +// an abrupt process crash: the lease is no longer renewed and the surviving pod |
| 21 | +// acquires leadership after the lease expires. |
| 22 | +// |
| 23 | +// Note: stopping the kind node container is not used here because both nodes in the |
| 24 | +// experimental 2-node cluster are control-plane nodes that run etcd — stopping either |
| 25 | +// would break etcd quorum and make the API server unreachable for the rest of the test. |
| 26 | +func CatalogdLeaderPodIsForceDeleted(ctx context.Context) error { |
| 27 | + sc := scenarioCtx(ctx) |
| 28 | + leaderPod := sc.leaderPods["catalogd"] |
| 29 | + if leaderPod == "" { |
| 30 | + return fmt.Errorf("catalogd leader pod not found in scenario context; run 'catalogd is ready to reconcile resources' first") |
| 31 | + } |
| 32 | + |
| 33 | + logger.Info("Force-deleting catalogd leader pod", "pod", leaderPod) |
| 34 | + if _, err := k8sClient("delete", "pod", leaderPod, "-n", olmNamespace, |
| 35 | + "--force", "--grace-period=0"); err != nil { |
| 36 | + return fmt.Errorf("failed to force-delete catalogd leader pod %q: %w", leaderPod, err) |
| 37 | + } |
| 38 | + return nil |
| 39 | +} |
| 40 | + |
| 41 | +// NewCatalogdLeaderIsElected polls the catalogd leader election lease until the holder |
| 42 | +// identity changes to a pod other than the deleted leader. It updates |
| 43 | +// sc.leaderPods["catalogd"] with the new leader pod name. |
| 44 | +func NewCatalogdLeaderIsElected(ctx context.Context) error { |
| 45 | + sc := scenarioCtx(ctx) |
| 46 | + oldLeader := sc.leaderPods["catalogd"] |
| 47 | + |
| 48 | + waitFor(ctx, func() bool { |
| 49 | + holder, err := k8sClient("get", "lease", leaseNames["catalogd"], "-n", olmNamespace, |
| 50 | + "-o", "jsonpath={.spec.holderIdentity}") |
| 51 | + if err != nil || holder == "" { |
| 52 | + return false |
| 53 | + } |
| 54 | + newPod := strings.Split(strings.TrimSpace(holder), "_")[0] |
| 55 | + if newPod == oldLeader { |
| 56 | + return false |
| 57 | + } |
| 58 | + sc.leaderPods["catalogd"] = newPod |
| 59 | + logger.Info("New catalogd leader elected", "pod", newPod) |
| 60 | + return true |
| 61 | + }) |
| 62 | + return nil |
| 63 | +} |
0 commit comments