framework

Documentation

Index

• Constants
• func ClusterNames() []string
• func Clusters() []*clusterv1alpha1.Cluster
• func CreateCRD(client dynamic.Interface, crd *apiextensionsv1.CustomResourceDefinition)
• func CreateClusterPropagationPolicy(client karmada.Interface, policy *policyv1alpha1.ClusterPropagationPolicy)
• func CreateDeployment(client kubernetes.Interface, deployment *appsv1.Deployment)
• func CreateJob(client kubernetes.Interface, job *batchv1.Job)
• func CreatePropagationPolicy(client karmada.Interface, policy *policyv1alpha1.PropagationPolicy)
• func GetCRD(client dynamic.Interface, name string)
• func GetClusterClient(clusterName string) kubernetes.Interface
• func GetClusterDynamicClient(clusterName string) dynamic.Interface
• func GetClusterNamesFromClusters(clusters []*clusterv1alpha1.Cluster) []string
• func GetJob(client kubernetes.Interface, namespace, name string)
• func InitClusterInformation(karmadaClient karmada.Interface, controlPlaneClient client.Client)
• func RemoveCRD(client dynamic.Interface, name string)
• func RemoveClusterPropagationPolicy(client karmada.Interface, name string)
• func RemoveDeployment(client kubernetes.Interface, namespace, name string)
• func RemoveJob(client kubernetes.Interface, namespace, name string)
• func RemovePropagationPolicy(client karmada.Interface, namespace, name string)
• func UpdateDeploymentReplicas(client kubernetes.Interface, deployment *appsv1.Deployment, replicas int32)
• func WaitCRDDisappearedOnClusters(clusters []string, crdName string)
• func WaitCRDPresentOnClusters(client karmada.Interface, clusters []string, crdAPIVersion, crdKind string)
• func WaitDeploymentDisappearOnClusters(clusters []string, namespace, name string)
• func WaitDeploymentPresentOnClusterFitWith(client kubernetes.Interface, namespace, name string, ...)
• func WaitDeploymentPresentOnClusters(clusters []string, namespace, name string)

Constants

const (
	// MinimumCluster represents the minimum number of member clusters to run E2E test.
	MinimumCluster = 2
)

Functions

func ClusterNames

func ClusterNames() []string

ClusterNames will return all member clusters' names we have.

func Clusters

func Clusters() []*clusterv1alpha1.Cluster

Clusters will return all member clusters we have.

func CreateCRD

func CreateCRD(client dynamic.Interface, crd *apiextensionsv1.CustomResourceDefinition)

CreateCRD create CustomResourceDefinition with dynamic client.

func CreateClusterPropagationPolicy

func CreateClusterPropagationPolicy(client karmada.Interface, policy *policyv1alpha1.ClusterPropagationPolicy)

CreateClusterPropagationPolicy create ClusterPropagationPolicy with karmada client.

func CreateDeployment

func CreateDeployment(client kubernetes.Interface, deployment *appsv1.Deployment)

CreateDeployment create Deployment.

func CreateJob

func CreateJob(client kubernetes.Interface, job *batchv1.Job)

CreateJob create Job.

func CreatePropagationPolicy

func CreatePropagationPolicy(client karmada.Interface, policy *policyv1alpha1.PropagationPolicy)

CreatePropagationPolicy create PropagationPolicy with karmada client.

func GetCRD

func GetCRD(client dynamic.Interface, name string)

GetCRD get CustomResourceDefinition with dynamic client.

func GetClusterClient

func GetClusterClient(clusterName string) kubernetes.Interface

GetClusterClient get cluster client

func GetClusterDynamicClient

func GetClusterDynamicClient(clusterName string) dynamic.Interface

GetClusterDynamicClient get cluster dynamicClient

func GetClusterNamesFromClusters

func GetClusterNamesFromClusters(clusters []*clusterv1alpha1.Cluster) []string

GetClusterNamesFromClusters will get Clusters' names form Clusters Object.

func GetJob

func GetJob(client kubernetes.Interface, namespace, name string)

GetJob get Job.

func InitClusterInformation

func InitClusterInformation(karmadaClient karmada.Interface, controlPlaneClient client.Client)

InitClusterInformation init the E2E test's cluster information.

func RemoveCRD

func RemoveCRD(client dynamic.Interface, name string)

RemoveCRD delete CustomResourceDefinition with dynamic client.

func RemoveClusterPropagationPolicy

func RemoveClusterPropagationPolicy(client karmada.Interface, name string)

RemoveClusterPropagationPolicy delete ClusterPropagationPolicy with karmada client.

func RemoveDeployment

func RemoveDeployment(client kubernetes.Interface, namespace, name string)

RemoveDeployment delete Deployment.

func RemoveJob

func RemoveJob(client kubernetes.Interface, namespace, name string)

RemoveJob delete Job.

func RemovePropagationPolicy

func RemovePropagationPolicy(client karmada.Interface, namespace, name string)

RemovePropagationPolicy delete PropagationPolicy with karmada client.

func UpdateDeploymentReplicas

func UpdateDeploymentReplicas(client kubernetes.Interface, deployment *appsv1.Deployment, replicas int32)

UpdateDeploymentReplicas update deployment's replicas.

func WaitCRDDisappearedOnClusters

func WaitCRDDisappearedOnClusters(clusters []string, crdName string)

WaitCRDDisappearedOnClusters wait CustomResourceDefinition disappear on clusters until timeout.

func WaitCRDPresentOnClusters

func WaitCRDPresentOnClusters(client karmada.Interface, clusters []string, crdAPIVersion, crdKind string)

WaitCRDPresentOnClusters wait CustomResourceDefinition present on clusters until timeout.

func WaitDeploymentDisappearOnClusters

func WaitDeploymentDisappearOnClusters(clusters []string, namespace, name string)

WaitDeploymentDisappearOnClusters wait deployment disappear on member clusters until timeout.

func WaitDeploymentPresentOnClusterFitWith

func WaitDeploymentPresentOnClusterFitWith(client kubernetes.Interface, namespace, name string, fit func(deployment *appsv1.Deployment) bool)

WaitDeploymentPresentOnClusterFitWith wait deployment present on member clusters fit with fit func.

func WaitDeploymentPresentOnClusters

func WaitDeploymentPresentOnClusters(clusters []string, namespace, name string)

WaitDeploymentPresentOnClusters wait deployment present on member clusters until timeout.