Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
veezhang committed Jun 4, 2021
1 parent eaeff88 commit e74ffbd
Show file tree
Hide file tree
Showing 8 changed files with 88 additions and 279 deletions.
2 changes: 1 addition & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ test: manifests generate check ## Run tests.

##@ e2e
e2e: $(GOBIN)/ginkgo $(GOBIN)/kind helm
./hack/e2e.sh
PATH="${GOBIN}:${PATH}" ./hack/e2e.sh

##@ Build

Expand Down
1 change: 1 addition & 0 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ require (
github.com/gin-gonic/gin v1.6.3
github.com/go-logr/logr v0.3.0
github.com/google/go-cmp v0.5.2
github.com/onsi/ginkgo v1.14.1
github.com/onsi/gomega v1.10.2
github.com/openkruise/kruise-api v0.8.0
github.com/pkg/errors v0.9.1
Expand Down
249 changes: 0 additions & 249 deletions go.sum

Large diffs are not rendered by default.

40 changes: 28 additions & 12 deletions hack/e2e.sh
Original file line number Diff line number Diff line change
Expand Up @@ -16,28 +16,40 @@

set -euo pipefail

ROOT=$(cd $(dirname "${BASH_SOURCE[0]}")/.. && pwd)
ROOT=$(cd "$(dirname "${BASH_SOURCE[0]}")/.." && pwd)

INSTALL_KUBERNETES=${INSTALL_KUBERNETES:-true}
UNINSTALL_KUBERNETES=${UNINSTALL_KUBERNETES:-true}
INSTALL_CERT_MANAGER=${INSTALL_CERT_MANAGER:-true}
INSTALL_CERT_MANAGER_VERSION=${INSTALL_CERT_MANAGER_VERSION:-v1.3.1}
INSTALL_KRUISE=${INSTALL_KRUISE:-true}
INSTALL_KRUISE_VERSION=${INSTALL_KRUISE_VERSION:-v0.8.1}
INSTALL_NEBULA_OPERATOR=${INSTALL_NEBULA_OPERATOR:-true}
KIND_NAME=${KIND_NAME:-e2e-test}
KIND_CONFIG=${KIND_CONFIG:-${ROOT}/hack/kind-config.yaml}
STORAGE_CLASS=${STORAGE_CLASS:-}
NEBULA_VERSION=${NEBULA_VERSION:-v2-nightly}

KUBECONFIG=${KUBECONFIG:-~/.kube/${KIND_NAME}.kind.config}
if [[ "${INSTALL_KUBERNETES}" == "true" ]];then
KUBECONFIG=~/.kube/${KIND_NAME}.kind.config
else
KUBECONFIG=${KUBECONFIG:-~/.kube/config}
fi
DELETE_NAMESPACE=${DELETE_NAMESPACE:-true}
DELETE_NAMESPACE_ON_FAILURE=${DELETE_NAMESPACE_ON_FAILURE:-false}

echo "starting e2e tests"
echo "INSTALL_KUBERNETES: ${INSTALL_KUBERNETES}"
echo "UNINSTALL_KUBERNETES: ${UNINSTALL_KUBERNETES}"
echo "INSTALL_CERT_MANAGER: ${INSTALL_CERT_MANAGER}"
echo "INSTALL_CERT_MANAGER_VERSION: ${INSTALL_CERT_MANAGER_VERSION}"
echo "INSTALL_KRUISE: ${INSTALL_KRUISE}"
echo "INSTALL_KRUISE_VERSION: ${INSTALL_KRUISE_VERSION}"
echo "INSTALL_NEBULA_OPERATOR: ${INSTALL_NEBULA_OPERATOR}"
echo "KIND_NAME: ${KIND_NAME}"
echo "KIND_CONFIG: ${KIND_CONFIG}"
echo "STORAGE_CLASS: ${STORAGE_CLASS}"
echo "NEBULA_VERSION: ${NEBULA_VERSION}"

echo "KUBECONFIG: ${KUBECONFIG}"
echo "DELETE_NAMESPACE: ${DELETE_NAMESPACE}"
Expand All @@ -46,14 +58,18 @@ echo "DELETE_NAMESPACE_ON_FAILURE: ${DELETE_NAMESPACE_ON_FAILURE}"

ginkgo ./tests/e2e \
-- \
--install-kubernetes=${INSTALL_KUBERNETES} \
--uninstall-kubernetes=${UNINSTALL_KUBERNETES} \
--install-cert-manager=${INSTALL_CERT_MANAGER} \
--install-kruise=${INSTALL_KRUISE} \
--install-nebula-operator=${INSTALL_NEBULA_OPERATOR} \
--kind-name=${KIND_NAME} \
--kind-config=${KIND_CONFIG} \
--kubeconfig=${KUBECONFIG} \
--delete-namespace=${DELETE_NAMESPACE} \
--delete-namespace-on-failure=${DELETE_NAMESPACE_ON_FAILURE} \
--install-kubernetes="${INSTALL_KUBERNETES}" \
--uninstall-kubernetes="${UNINSTALL_KUBERNETES}" \
--install-cert-manager="${INSTALL_CERT_MANAGER}" \
--install-cert-manager-version="${INSTALL_CERT_MANAGER_VERSION}" \
--install-kruise="${INSTALL_KRUISE}" \
--install-kruise-version="${INSTALL_KRUISE_VERSION}" \
--install-nebula-operator="${INSTALL_NEBULA_OPERATOR}" \
--kind-name="${KIND_NAME}" \
--kind-config="${KIND_CONFIG}" \
--storage-class="${STORAGE_CLASS}" \
--nebula-version="${NEBULA_VERSION}" \
--kubeconfig="${KUBECONFIG}" \
--delete-namespace="${DELETE_NAMESPACE}" \
--delete-namespace-on-failure="${DELETE_NAMESPACE_ON_FAILURE}" \
"${@}"
31 changes: 23 additions & 8 deletions tests/e2e/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,19 +21,25 @@ import (
)

const (
DefaultKindName = "e2e-test"
DefaultKindName = "e2e-test"
DefaultInstallCertManagerVersion = "v1.3.1"
DefaultInstallKruiseVersion = "v0.8.1"
)

var TestConfig Config

type Config struct {
InstallKubernetes bool
UninstallKubernetes bool
InstallCertManager bool
InstallKruise bool
InstallNebulaOperator bool
KindName string
KindConfig string
InstallKubernetes bool
UninstallKubernetes bool
InstallCertManager bool
InstallCertManagerVersion string
InstallKruise bool
InstallKruiseVersion string
InstallNebulaOperator bool
KindName string
KindConfig string
StorageClass string
NebulaVersion string
}

func RegisterClusterFlags(flags *flag.FlagSet) {
Expand All @@ -43,12 +49,21 @@ func RegisterClusterFlags(flags *flag.FlagSet) {
"If true tests will uninstall kubernetes. Ignored when --install-kubernetes is false.")
flags.BoolVar(&TestConfig.InstallCertManager, "install-cert-manager", true,
"If true tests will install cert-manager.")
flags.StringVar(&TestConfig.InstallCertManagerVersion, "install-cert-manager-version", DefaultInstallCertManagerVersion,
"The cert-manager version to install.")
flags.BoolVar(&TestConfig.InstallKruise, "install-kruise", true,
"If true tests will install kruise.")
flags.StringVar(&TestConfig.InstallKruiseVersion, "install-kruise-version", DefaultInstallKruiseVersion,
"The kruise version to install.")
flags.BoolVar(&TestConfig.InstallNebulaOperator, "install-nebula-operator", true,
"If true tests will install nebula operator.")
flags.StringVar(&TestConfig.KindName, "kind-name", DefaultKindName,
"The kind name to install.")
flags.StringVar(&TestConfig.KindConfig, "kind-config", "../../hack/kind-config.yaml",
"The kind config to install.")
flags.StringVar(&TestConfig.StorageClass, "storage-class", "",
"The storage class to use to install nebula cluster."+
"If don't configure, use the default storage class and then the others in the kubernetes.")
flags.StringVar(&TestConfig.NebulaVersion, "nebula-version", "v2-nightly",
"The nebula version.")
}
4 changes: 2 additions & 2 deletions tests/e2e/nebulacluster/nebulacluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ var _ = ginkgo.Describe("NebulaCluster", func() {

var err error
// init the NebulaCluster Resource for testing
nc := getNebulaCluster(ns, tc.Name)
nc := getNebulaCluster(runtimeClient, ns, tc.Name)
nc.Spec.Graphd.Replicas = pointer.Int32Ptr(tc.GraphdReplicas)
nc.Spec.Metad.Replicas = pointer.Int32Ptr(tc.MetadReplicas)
nc.Spec.Storaged.Replicas = pointer.Int32Ptr(tc.StoragedReplicas)
Expand Down Expand Up @@ -183,7 +183,7 @@ var _ = ginkgo.Describe("NebulaCluster", func() {
ginkgo.By("Deploy NebulaCluster")
var err error

nc := getNebulaCluster(ns, "test-recovery")
nc := getNebulaCluster(runtimeClient, ns, "test-recovery")
nc.Spec.Graphd.Replicas = pointer.Int32Ptr(2)
nc.Spec.Metad.Replicas = pointer.Int32Ptr(3)
nc.Spec.Storaged.Replicas = pointer.Int32Ptr(4)
Expand Down
36 changes: 31 additions & 5 deletions tests/e2e/nebulacluster/util.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,25 +25,29 @@ import (

appsv1 "k8s.io/api/apps/v1"
corev1 "k8s.io/api/core/v1"
storagev1 "k8s.io/api/storage/v1"
apierrors "k8s.io/apimachinery/pkg/api/errors"
"k8s.io/apimachinery/pkg/api/resource"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/apimachinery/pkg/util/wait"
"k8s.io/client-go/rest"
storageutil "k8s.io/kubernetes/pkg/apis/storage/util"
"k8s.io/kubernetes/test/e2e/framework"
"k8s.io/utils/pointer"
"sigs.k8s.io/controller-runtime/pkg/client"

nebula "github.com/vesoft-inc/nebula-go"
"github.com/vesoft-inc/nebula-operator/apis/apps/v1alpha1"
"github.com/vesoft-inc/nebula-operator/pkg/label"
e2econfig "github.com/vesoft-inc/nebula-operator/tests/e2e/config"
e2eutil "github.com/vesoft-inc/nebula-operator/tests/e2e/util"
)

func getNebulaCluster(namespace, name string) *v1alpha1.NebulaCluster {
func getNebulaCluster(runtimeClient client.Client, namespace, name string) *v1alpha1.NebulaCluster {
imagePullPolicy := corev1.PullIfNotPresent
storageClassName := "standard" // standard, fast-disks
storageClassName := getStorageClassName(runtimeClient)
nebulaVersion := e2econfig.TestConfig.NebulaVersion
return &v1alpha1.NebulaCluster{
ObjectMeta: metav1.ObjectMeta{
Name: name,
Expand All @@ -54,7 +58,7 @@ func getNebulaCluster(namespace, name string) *v1alpha1.NebulaCluster {
PodSpec: v1alpha1.PodSpec{
Replicas: pointer.Int32Ptr(1),
Image: "vesoft/nebula-graphd",
Version: "v2-nightly",
Version: nebulaVersion,
},
StorageClaim: &v1alpha1.StorageClaim{
StorageClassName: &storageClassName,
Expand All @@ -69,7 +73,7 @@ func getNebulaCluster(namespace, name string) *v1alpha1.NebulaCluster {
PodSpec: v1alpha1.PodSpec{
Replicas: pointer.Int32Ptr(1),
Image: "vesoft/nebula-metad",
Version: "v2-nightly",
Version: nebulaVersion,
},
StorageClaim: &v1alpha1.StorageClaim{
StorageClassName: &storageClassName,
Expand All @@ -84,7 +88,7 @@ func getNebulaCluster(namespace, name string) *v1alpha1.NebulaCluster {
PodSpec: v1alpha1.PodSpec{
Replicas: pointer.Int32Ptr(1),
Image: "vesoft/nebula-storaged",
Version: "v2-nightly",
Version: nebulaVersion,
},
StorageClaim: &v1alpha1.StorageClaim{
StorageClassName: &storageClassName,
Expand All @@ -105,6 +109,28 @@ func getNebulaCluster(namespace, name string) *v1alpha1.NebulaCluster {
}
}

func getStorageClassName(runtimeClient client.Client) string {
if e2econfig.TestConfig.StorageClass != "" {
return e2econfig.TestConfig.StorageClass
}

var scList storagev1.StorageClassList
err := runtimeClient.List(context.TODO(), &scList)
framework.ExpectNoError(err, "failed to list StorageClass")
framework.ExpectNotEqual(len(scList.Items), 0, "don't find StorageClass")
var scName string
for i := range scList.Items {
sc := scList.Items[i]
if storageutil.IsDefaultAnnotation(sc.ObjectMeta) {
return sc.GetName()
}
if scName == "" {
scName = sc.GetName()
}
}
return scName
}

func waitForNebulaClusterReady(
nc *v1alpha1.NebulaCluster,
timeout, pollInterval time.Duration,
Expand Down
4 changes: 2 additions & 2 deletions tests/e2e/suites.go
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ func setupCertManager() {
"--repo", "https://charts.jetstack.io",
"--namespace", helmNamespace,
"--create-namespace",
"--version", "v1.3.1",
"--version", e2econfig.TestConfig.InstallCertManagerVersion,
"--set", "installCRDs=true",
}
helmInstall(helmName, helmNamespace, workloadNamespaces, helmArgs...)
Expand All @@ -144,7 +144,7 @@ func setupKruise() {
workloadNamespaces := []string{"kruise-system"}
helmArgs := []string{
"install", helmName,
"https://github.com/openkruise/kruise/releases/download/v0.8.1/kruise-chart.tgz",
fmt.Sprintf("https://github.com/openkruise/kruise/releases/download/%s/kruise-chart.tgz", e2econfig.TestConfig.InstallKruiseVersion),
}
helmInstall(helmName, helmNamespace, workloadNamespaces, helmArgs...)
}
Expand Down

0 comments on commit e74ffbd

Please sign in to comment.