mirror of
https://github.com/open-cluster-management-io/ocm.git
synced 2026-09-05 08:47:21 +00:00
63 lines
2.4 KiB
Go
63 lines
2.4 KiB
Go
package e2e
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
. "github.com/onsi/ginkgo"
|
|
. "github.com/onsi/gomega"
|
|
"k8s.io/apimachinery/pkg/util/rand"
|
|
)
|
|
|
|
var _ = Describe("Manage the managed cluster addons", func() {
|
|
var klusterletName = fmt.Sprintf("e2e-klusterlet-%s", rand.String(6))
|
|
var clusterName = fmt.Sprintf("e2e-managedcluster-%s", rand.String(6))
|
|
var agentNamespace = fmt.Sprintf("e2e-agent-%s", rand.String(6))
|
|
var addOnName = fmt.Sprintf("e2e-addon-%s", rand.String(6))
|
|
|
|
AfterEach(func() {
|
|
By(fmt.Sprintf("clean klusterlet %v resources after the test case", klusterletName))
|
|
t.cleanKlusterletResources(klusterletName, clusterName)
|
|
})
|
|
|
|
It("Create one managed cluster addon and make sure it is available", func() {
|
|
var err error
|
|
By(fmt.Sprintf("create klusterlet %v with managed cluster name %v", klusterletName, clusterName))
|
|
_, err = t.CreateKlusterlet(klusterletName, clusterName, agentNamespace)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
|
|
By(fmt.Sprintf("waiting for the managed cluster %v to be created", clusterName))
|
|
Eventually(func() error {
|
|
_, err = t.GetCreatedManagedCluster(clusterName)
|
|
return err
|
|
}, t.EventuallyTimeout*5, t.EventuallyInterval*5).Should(Succeed())
|
|
|
|
By(fmt.Sprintf("approve the created managed cluster %v", clusterName))
|
|
Eventually(func() error {
|
|
return t.ApproveCSR(clusterName)
|
|
}, t.EventuallyTimeout, t.EventuallyInterval).Should(Succeed())
|
|
|
|
By(fmt.Sprintf("accept the created managed cluster %v", clusterName))
|
|
Eventually(func() error {
|
|
return t.AcceptsClient(clusterName)
|
|
}, t.EventuallyTimeout, t.EventuallyInterval).Should(Succeed())
|
|
|
|
By(fmt.Sprintf("waiting for the managed cluster %v to be ready", clusterName))
|
|
Eventually(func() error {
|
|
return t.CheckManagedClusterStatus(clusterName)
|
|
}, t.EventuallyTimeout*5, t.EventuallyInterval*5).Should(Succeed())
|
|
|
|
By(fmt.Sprintf("create the addon %v on the managed cluster namespace %v", addOnName, clusterName))
|
|
err = t.CreateManagedClusterAddOn(clusterName, addOnName)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
|
|
By(fmt.Sprintf("create the addon lease %v on addon install namespace %v", addOnName, addOnName))
|
|
err = t.CreateManagedClusterAddOnLease(addOnName, addOnName)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
|
|
By(fmt.Sprintf("wait the addon %v available condition to be true", addOnName))
|
|
Eventually(func() error {
|
|
return t.CheckManagedClusterAddOnStatus(clusterName, addOnName)
|
|
}, t.EventuallyTimeout*5, t.EventuallyInterval*5).Should(Succeed())
|
|
})
|
|
})
|