-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
test: include e2e test for KCP adoption
- Loading branch information
Showing
7 changed files
with
382 additions
and
72 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,118 @@ | ||
| package framework | ||
|
|
||
| import ( | ||
| "context" | ||
|
|
||
| . "github.com/onsi/ginkgo" | ||
| . "github.com/onsi/gomega" | ||
| "github.com/pkg/errors" | ||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| "k8s.io/apimachinery/pkg/runtime" | ||
| clusterv1 "sigs.k8s.io/cluster-api/api/v1alpha3" | ||
| "sigs.k8s.io/controller-runtime/pkg/client" | ||
| ) | ||
|
|
||
| // CreateMachineInput is the input for CreateMachine. | ||
| type CreateMachineInput struct { | ||
| Creator Creator | ||
| Machine *clusterv1.Machine | ||
| BootstrapConfig runtime.Object | ||
| InfraMachine runtime.Object | ||
| } | ||
|
|
||
| // CreateMachine creates the machine and dependencies. | ||
| func CreateMachine(ctx context.Context, input CreateMachineInput) { | ||
| By("creating a core Machine resource") | ||
| Expect(input.Creator.Create(ctx, input.Machine)).To(Succeed()) | ||
|
|
||
| By("creating a BootstrapConfigTemplate resource") | ||
| Expect(input.Creator.Create(ctx, input.BootstrapConfig)).To(Succeed()) | ||
|
|
||
| By("creating an InfrastructureMachineTemplate resource") | ||
| Expect(input.Creator.Create(ctx, input.InfraMachine)).To(Succeed()) | ||
| } | ||
|
|
||
| // WaitForMachineNodesToExistInput is the input for WaitForMachineNodesToExist. | ||
| type WaitForMachineNodesToExistInput struct { | ||
| Getter Getter | ||
| Machines []*clusterv1.Machine | ||
| } | ||
|
|
||
| // WaitForMachineDeploymentNodesToExist waits until all nodes associated with a machine deployment exist. | ||
| func WaitForMachineNodesToExist(ctx context.Context, input WaitForMachineNodesToExistInput, intervals ...interface{}) { | ||
| By("waiting for the machines' nodes to exist") | ||
| Eventually(func() (count int, err error) { | ||
| for _, m := range input.Machines { | ||
| machine := &clusterv1.Machine{} | ||
| err = input.Getter.Get(ctx, client.ObjectKey{Namespace: m.Namespace, Name: m.Name}, machine) | ||
| if err != nil { | ||
| return | ||
| } | ||
| if machine.Status.NodeRef != nil { | ||
| count++ | ||
| } | ||
| } | ||
| return | ||
| }, intervals...).Should(Equal(len(input.Machines))) | ||
| } | ||
|
|
||
| // CreateMachineDeploymentInput is the input for CreateMachineDeployment. | ||
| type CreateMachineDeploymentInput struct { | ||
| Creator Creator | ||
| MachineDeployment *clusterv1.MachineDeployment | ||
| BootstrapConfigTemplate runtime.Object | ||
| InfraMachineTemplate runtime.Object | ||
| } | ||
|
|
||
| // CreateMachineDeployment creates the machine deployment and dependencies. | ||
| func CreateMachineDeployment(ctx context.Context, input CreateMachineDeploymentInput) { | ||
| By("creating a core MachineDeployment resource") | ||
| Expect(input.Creator.Create(ctx, input.MachineDeployment)).To(Succeed()) | ||
|
|
||
| By("creating a BootstrapConfigTemplate resource") | ||
| Expect(input.Creator.Create(ctx, input.BootstrapConfigTemplate)).To(Succeed()) | ||
|
|
||
| By("creating an InfrastructureMachineTemplate resource") | ||
| Expect(input.Creator.Create(ctx, input.InfraMachineTemplate)).To(Succeed()) | ||
| } | ||
|
|
||
| // WaitForMachineDeploymentNodesToExistInput is the input for WaitForMachineDeploymentNodesToExist. | ||
| type WaitForMachineDeploymentNodesToExistInput struct { | ||
| Lister Lister | ||
| Cluster *clusterv1.Cluster | ||
| MachineDeployment *clusterv1.MachineDeployment | ||
| } | ||
|
|
||
| // WaitForMachineDeploymentNodesToExist waits until all nodes associated with a machine deployment exist. | ||
| func WaitForMachineDeploymentNodesToExist(ctx context.Context, input WaitForMachineDeploymentNodesToExistInput, intervals ...interface{}) { | ||
| By("waiting for the workload nodes to exist") | ||
| Eventually(func() (int, error) { | ||
| selectorMap, err := metav1.LabelSelectorAsMap(&input.MachineDeployment.Spec.Selector) | ||
| if err != nil { | ||
| return 0, err | ||
| } | ||
| ms := &clusterv1.MachineSetList{} | ||
| if err := input.Lister.List(ctx, ms, client.InNamespace(input.Cluster.Namespace), client.MatchingLabels(selectorMap)); err != nil { | ||
| return 0, err | ||
| } | ||
| if len(ms.Items) == 0 { | ||
| return 0, errors.New("no machinesets were found") | ||
| } | ||
| machineSet := ms.Items[0] | ||
| selectorMap, err = metav1.LabelSelectorAsMap(&machineSet.Spec.Selector) | ||
| if err != nil { | ||
| return 0, err | ||
| } | ||
| machines := &clusterv1.MachineList{} | ||
| if err := input.Lister.List(ctx, machines, client.InNamespace(machineSet.Namespace), client.MatchingLabels(selectorMap)); err != nil { | ||
| return 0, err | ||
| } | ||
| count := 0 | ||
| for _, machine := range machines.Items { | ||
| if machine.Status.NodeRef != nil { | ||
| count++ | ||
| } | ||
| } | ||
| return count, nil | ||
| }, intervals...).Should(Equal(int(*input.MachineDeployment.Spec.Replicas))) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.