github/open-cluster-management
1
0
Fork 0
mirror of https://github.com/open-cluster-management-io/ocm.git synced 2026-05-26 19:16:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

add heartbeat e2e test case

Browse Source
This commit is contained in:
liuwei
2020-06-15 15:33:40 +08:00
parent f1fdd1c7c1
commit c87bf16c98
1 changed files with 77 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
test/e2e/loopback_test.go
View File

@@ -228,13 +228,14 @@ var _ = ginkgo.Describe("Loopback registration [development]", func() {
gomega.Expect(err).ToNot(gomega.HaveOccurred())
managedCluster.Spec.HubAcceptsClient = true
managedCluster.Spec.LeaseDurationSeconds = 5
managedCluster, err = managedClusters.Update(context.TODO(), managedCluster, metav1.UpdateOptions{})
return err
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
ginkgo.By("Waiting for ManagedCluster to have HubAccepted=true")
err = wait.Poll(1*time.Second, 30*time.Second, func() (bool, error) {
err = wait.Poll(1*time.Second, 90*time.Second, func() (bool, error) {
var err error
managedCluster, err := managedClusters.Get(context.TODO(), clusterName, metav1.GetOptions{})
if err != nil {
@@ -253,6 +254,81 @@ var _ = ginkgo.Describe("Loopback registration [development]", func() {
return false, nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
ginkgo.By("Waiting for ManagedCluster to join the hub cluser")
err = wait.Poll(1*time.Second, 90*time.Second, func() (bool, error) {
var err error
managedCluster, err := managedClusters.Get(context.TODO(), clusterName, metav1.GetOptions{})
if err != nil {
return false, err
}
condition := helpers.FindManagedClusterCondition(managedCluster.Status.Conditions, clusterv1.ManagedClusterConditionJoined)
return helpers.IsConditionTrue(condition), nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
ginkgo.By("Waiting for ManagedCluster available")
err = wait.Poll(1*time.Second, 90*time.Second, func() (bool, error) {
managedCluster, err := managedClusters.Get(context.TODO(), clusterName, metav1.GetOptions{})
if err != nil {
return false, err
}
condition := helpers.FindManagedClusterCondition(managedCluster.Status.Conditions, clusterv1.ManagedClusterConditionAvailable)
return helpers.IsConditionTrue(condition), nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
leaseName := fmt.Sprintf("cluster-lease-%s", clusterName)
ginkgo.By(fmt.Sprintf("Make sure ManagedCluster lease %q exists", leaseName))
var lastRenewTime *metav1.MicroTime
err = wait.Poll(1*time.Second, 30*time.Second, func() (bool, error) {
lease, err := hubClient.CoordinationV1().Leases(clusterName).Get(context.TODO(), leaseName, metav1.GetOptions{})
if err != nil {
return false, err
}
lastRenewTime = lease.Spec.RenewTime
return true, nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
ginkgo.By(fmt.Sprintf("Make sure ManagedCluster lease %q is updated", leaseName))
err = wait.Poll(1*time.Second, 30*time.Second, func() (bool, error) {
lease, err := hubClient.CoordinationV1().Leases(clusterName).Get(context.TODO(), leaseName, metav1.GetOptions{})
if err != nil {
return false, err
}
leaseUpdated := lastRenewTime.Before(lease.Spec.RenewTime)
if leaseUpdated {
lastRenewTime = lease.Spec.RenewTime
}
return leaseUpdated, nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
ginkgo.By(fmt.Sprintf("Make sure ManagedCluster lease %q is updated again", leaseName))
err = wait.Poll(1*time.Second, 30*time.Second, func() (bool, error) {
lease, err := hubClient.CoordinationV1().Leases(clusterName).Get(context.TODO(), leaseName, metav1.GetOptions{})
if err != nil {
return false, err
}
return lastRenewTime.Before(lease.Spec.RenewTime), nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
ginkgo.By("Make sure ManagedCluster is still available")
err = wait.Poll(1*time.Second, 30*time.Second, func() (bool, error) {
managedCluster, err := managedClusters.Get(context.TODO(), clusterName, metav1.GetOptions{})
if err != nil {
return false, err
}
condition := helpers.FindManagedClusterCondition(managedCluster.Status.Conditions, clusterv1.ManagedClusterConditionAvailable)
return helpers.IsConditionTrue(condition), nil
})
gomega.Expect(err).ToNot(gomega.HaveOccurred())
})
})