framework

package
v1.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 25, 2022 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func CheckDeploymentReadyStatus added in v1.2.0 

func CheckDeploymentReadyStatus(deployment *appsv1.Deployment, wantedReplicas int32) bool

CheckDeploymentReadyStatus check the deployment status By checking the replicas

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 CreateClusterRole added in v1.2.0 

func CreateClusterRole(client kubernetes.Interface, clusterRole *rbacv1.ClusterRole)

CreateClusterRole create clusterRole.

func CreateClusterRoleBinding added in v1.2.0 

func CreateClusterRoleBinding(client kubernetes.Interface, clusterRoleBinding *rbacv1.ClusterRoleBinding)

CreateClusterRoleBinding create clusterRoleBinding.

func CreateConfigMap added in v1.2.0 

func CreateConfigMap(client kubernetes.Interface, configMap *corev1.ConfigMap)

CreateConfigMap create ConfigMap.

func CreateDaemonSet added in v1.2.0 

func CreateDaemonSet(client kubernetes.Interface, daemonSet *appsv1.DaemonSet)

CreateDaemonSet create DaemonSet.

func CreateDeployment 

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

CreateDeployment create Deployment.

func CreateFederatedResourceQuota added in v1.2.0 

func CreateFederatedResourceQuota(client karmada.Interface, federatedResourceQuota *policyv1alpha1.FederatedResourceQuota)

CreateFederatedResourceQuota create FederatedResourceQuota with karmada client.

func CreateIngress added in v1.2.0 

func CreateIngress(client kubernetes.Interface, ingress *networkingv1.Ingress)

CreateIngress create Ingress.

func CreateJob 

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

CreateJob create Job.

func CreateNamespace added in v1.0.0 

func CreateNamespace(client kubernetes.Interface, namespace *corev1.Namespace)

CreateNamespace create Namespace.

func CreateOverridePolicy added in v1.0.0 

func CreateOverridePolicy(client karmada.Interface, policy *policyv1alpha1.OverridePolicy)

CreateOverridePolicy create OverridePolicy with karmada client.

func CreatePod added in v1.0.0 

func CreatePod(client kubernetes.Interface, pod *corev1.Pod)

CreatePod create Pod.

func CreatePropagationPolicy 

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

CreatePropagationPolicy create PropagationPolicy with karmada client.

func CreateSecret added in v1.2.0 

func CreateSecret(client kubernetes.Interface, secret *corev1.Secret)

CreateSecret create Secret.

func CreateService added in v1.0.0 

func CreateService(client kubernetes.Interface, service *corev1.Service)

CreateService create Service.

func CreateServiceAccount added in v1.2.0 

func CreateServiceAccount(client kubernetes.Interface, serviceaccount *corev1.ServiceAccount)

CreateServiceAccount create serviceaccount.

func CreateStatefulSet added in v1.2.0 

func CreateStatefulSet(client kubernetes.Interface, statefulSet *appsv1.StatefulSet)

CreateStatefulSet create StatefulSet.

func CreateWorkload added in v1.0.0 

func CreateWorkload(client dynamic.Interface, workload *workloadv1alpha1.Workload)

CreateWorkload create Workload with dynamic client

func ExtractTargetClustersFrom added in v1.0.0 

func ExtractTargetClustersFrom(c client.Client, deployment *appsv1.Deployment) []string

ExtractTargetClustersFrom extract the target cluster names from deployment's related resourceBinding Information.

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 GetWorkload added in v1.0.0 

func GetWorkload(client dynamic.Interface, namespace, name string) *workloadv1alpha1.Workload

GetWorkload get Workload with dynamic client.

func InitClusterInformation 

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

InitClusterInformation init the E2E test's cluster information.

func PatchPropagationPolicy added in v1.2.0 

func PatchPropagationPolicy(client karmada.Interface, namespace, name string, patch []map[string]interface{}, patchType types.PatchType)

PatchPropagationPolicy patch PropagationPolicy with karmada client.

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 RemoveClusterRole added in v1.2.0 

func RemoveClusterRole(client kubernetes.Interface, name string)

RemoveClusterRole delete clusterRole.

func RemoveClusterRoleBinding added in v1.2.0 

func RemoveClusterRoleBinding(client kubernetes.Interface, name string)

RemoveClusterRoleBinding delete clusterRoleBinding.

func RemoveConfigMap added in v1.2.0 

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

RemoveConfigMap delete ConfigMap.

func RemoveDaemonSet added in v1.2.0 

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

RemoveDaemonSet delete DaemonSet.

func RemoveDeployment 

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

RemoveDeployment delete Deployment.

func RemoveFederatedResourceQuota added in v1.2.0 

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

RemoveFederatedResourceQuota delete FederatedResourceQuota with karmada client.

func RemoveIngress added in v1.2.0 

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

RemoveIngress delete Ingress.

func RemoveJob 

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

RemoveJob delete Job.

func RemoveNamespace added in v1.0.0 

func RemoveNamespace(client kubernetes.Interface, name string)

RemoveNamespace delete Namespace.

func RemoveOverridePolicy added in v1.0.0 

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

RemoveOverridePolicy delete OverridePolicy with karmada client.

func RemovePod added in v1.0.0 

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

RemovePod delete Pod.

func RemovePropagationPolicy 

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

RemovePropagationPolicy delete PropagationPolicy with karmada client.

func RemoveSecret added in v1.2.0 

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

RemoveSecret delete Secret.

func RemoveService added in v1.0.0 

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

RemoveService delete Service.

func RemoveServiceAccount added in v1.2.0 

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

RemoveServiceAccount delete serviceaccount.

func RemoveStatefulSet added in v1.2.0 

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

RemoveStatefulSet delete StatefulSet.

func RemoveWorkload added in v1.0.0 

func RemoveWorkload(client dynamic.Interface, namespace, name string)

RemoveWorkload delete Workload with dynamic client.

func SerialContext added in v1.2.0 

func SerialContext(text string, args ...interface{}) bool

SerialContext is wrapper function for ginkgo.Context with ginkgo.Serial decorator.

func SerialDescribe added in v1.2.0 

func SerialDescribe(text string, args ...interface{}) bool

SerialDescribe is wrapper function for ginkgo.Describe with ginkgo.Serial decorator.

func SerialWhen added in v1.2.0 

func SerialWhen(text string, args ...interface{}) bool

SerialWhen is wrapper function for ginkgo.When with ginkgo.Serial decorator.

func UpdateConfigMapWithPatch added in v1.2.0 

func UpdateConfigMapWithPatch(client kubernetes.Interface, namespace, name string, patch []map[string]interface{}, patchType types.PatchType)

UpdateConfigMapWithPatch update configmap with patch bytes.

func UpdateDeploymentAnnotations added in v1.0.0 

func UpdateDeploymentAnnotations(client kubernetes.Interface, deployment *appsv1.Deployment, annotations map[string]string)

UpdateDeploymentAnnotations update deployment's annotations.

func UpdateDeploymentReplicas 

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

UpdateDeploymentReplicas update deployment's replicas.

func UpdateDeploymentVolumes added in v1.2.0 

func UpdateDeploymentVolumes(client kubernetes.Interface, deployment *appsv1.Deployment, volumes []corev1.Volume)

UpdateDeploymentVolumes update Deployment's volumes.

func UpdateFederatedResourceQuotaWithPatch added in v1.2.0 

func UpdateFederatedResourceQuotaWithPatch(client karmada.Interface, namespace, name string, patch []map[string]interface{}, patchType types.PatchType)

UpdateFederatedResourceQuotaWithPatch update FederatedResourceQuota with patch bytes.

func UpdateJobWithPatchBytes added in v1.0.0 

func UpdateJobWithPatchBytes(client kubernetes.Interface, namespace, name string, patchBytes []byte, patchType types.PatchType)

UpdateJobWithPatchBytes update job with patch bytes.

func UpdatePodWithPatch added in v1.0.0 

func UpdatePodWithPatch(client kubernetes.Interface, namespace, name string, patch []map[string]interface{}, patchType types.PatchType)

UpdatePodWithPatch update pod with patch bytes.

func UpdateServiceWithPatch added in v1.0.0 

func UpdateServiceWithPatch(client kubernetes.Interface, namespace, name string, patch []map[string]interface{}, patchType types.PatchType)

UpdateServiceWithPatch update service with patch bytes.

func UpdateStatefulSetReplicas added in v1.2.0 

func UpdateStatefulSetReplicas(client kubernetes.Interface, statefulSet *appsv1.StatefulSet, replicas int32)

UpdateStatefulSetReplicas update statefulSet's replicas.

func UpdateWorkload added in v1.0.0 

func UpdateWorkload(client dynamic.Interface, workload *workloadv1alpha1.Workload, clusterName string, subresources ...string)

UpdateWorkload update Workload with dynamic client

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 WaitClusterFitWith added in v1.0.0 

func WaitClusterFitWith(c client.Client, clusterName string, fit func(cluster *clusterv1alpha1.Cluster) bool)

WaitClusterFitWith wait cluster fit with fit func.

func WaitConfigMapPresentOnClusterFitWith added in v1.2.0 

func WaitConfigMapPresentOnClusterFitWith(cluster, namespace, name string, fit func(configmap *corev1.ConfigMap) bool)

WaitConfigMapPresentOnClusterFitWith wait configmap present on member cluster sync with fit func.

func WaitConfigMapPresentOnClustersFitWith added in v1.2.0 

func WaitConfigMapPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(configmap *corev1.ConfigMap) bool)

WaitConfigMapPresentOnClustersFitWith wait configmap present on clusters sync with fit func.

func WaitDeploymentDisappearOnCluster added in v1.0.0 

func WaitDeploymentDisappearOnCluster(cluster, namespace, name string)

WaitDeploymentDisappearOnCluster wait deployment disappear on cluster until timeout.

func WaitDeploymentDisappearOnClusters 

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

WaitDeploymentDisappearOnClusters wait deployment disappear on member clusters until timeout.

func WaitDeploymentPresentOnClusterFitWith 

func WaitDeploymentPresentOnClusterFitWith(cluster, namespace, name string, fit func(deployment *appsv1.Deployment) bool)

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

func WaitDeploymentPresentOnClustersFitWith added in v1.0.0 

func WaitDeploymentPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(deployment *appsv1.Deployment) bool)

WaitDeploymentPresentOnClustersFitWith wait deployment present on cluster sync with fit func.

func WaitFederatedResourceQuotaCollectStatus added in v1.2.0 

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

WaitFederatedResourceQuotaCollectStatus wait FederatedResourceQuota collect status successfully.

func WaitJobDisappearOnCluster added in v1.0.0 

func WaitJobDisappearOnCluster(cluster, namespace, name string)

WaitJobDisappearOnCluster wait job disappear on cluster until timeout.

func WaitJobDisappearOnClusters added in v1.0.0 

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

WaitJobDisappearOnClusters wait job disappear on member clusters until timeout.

func WaitJobPresentOnClusterFitWith added in v1.0.0 

func WaitJobPresentOnClusterFitWith(cluster, namespace, name string, fit func(job *batchv1.Job) bool)

WaitJobPresentOnClusterFitWith wait job present on member clusters sync with fit func.

func WaitJobPresentOnClustersFitWith added in v1.0.0 

func WaitJobPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(job *batchv1.Job) bool)

WaitJobPresentOnClustersFitWith wait job present on cluster sync with fit func.

func WaitNamespaceDisappearOnCluster added in v1.0.0 

func WaitNamespaceDisappearOnCluster(cluster, name string)

WaitNamespaceDisappearOnCluster wait namespace disappear on cluster until timeout.

func WaitNamespaceDisappearOnClusters added in v1.0.0 

func WaitNamespaceDisappearOnClusters(clusters []string, name string)

WaitNamespaceDisappearOnClusters wait namespace disappear on clusters until timeout.

func WaitNamespacePresentOnCluster added in v1.0.0 

func WaitNamespacePresentOnCluster(cluster, name string)

WaitNamespacePresentOnCluster wait namespace present on cluster until timeout.

func WaitNamespacePresentOnClusterByClient added in v1.2.0 

func WaitNamespacePresentOnClusterByClient(client kubernetes.Interface, name string)

WaitNamespacePresentOnClusterByClient wait namespace present on cluster until timeout directly by kube client.

func WaitNamespacePresentOnClusters added in v1.0.0 

func WaitNamespacePresentOnClusters(clusters []string, name string)

WaitNamespacePresentOnClusters wait namespace present on clusters until timeout.

func WaitPodDisappearOnCluster added in v1.0.0 

func WaitPodDisappearOnCluster(cluster, namespace, name string)

WaitPodDisappearOnCluster wait pod disappear on cluster until timeout.

func WaitPodDisappearOnClusters added in v1.0.0 

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

WaitPodDisappearOnClusters wait pod disappear on member clusters until timeout.

func WaitPodPresentOnClusterFitWith added in v1.0.0 

func WaitPodPresentOnClusterFitWith(cluster, namespace, name string, fit func(pod *corev1.Pod) bool)

WaitPodPresentOnClusterFitWith wait pod present on member clusters sync with fit func.

func WaitPodPresentOnClustersFitWith added in v1.0.0 

func WaitPodPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(pod *corev1.Pod) bool)

WaitPodPresentOnClustersFitWith wait pod present on cluster sync with fit func.

func WaitResourceQuotaDisappearOnCluster added in v1.2.0 

func WaitResourceQuotaDisappearOnCluster(cluster, namespace, name string)

WaitResourceQuotaDisappearOnCluster wait resourceQuota disappear on one cluster until timeout.

func WaitResourceQuotaDisappearOnClusters added in v1.2.0 

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

WaitResourceQuotaDisappearOnClusters wait resourceQuota disappear on clusters until timeout.

func WaitResourceQuotaPresentOnCluster added in v1.2.0 

func WaitResourceQuotaPresentOnCluster(cluster, namespace, name string)

WaitResourceQuotaPresentOnCluster wait resourceQuota present on one cluster until timeout.

func WaitResourceQuotaPresentOnClusters added in v1.2.0 

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

WaitResourceQuotaPresentOnClusters wait resourceQuota present on clusters until timeout.

func WaitSecretDisappearOnCluster added in v1.2.0 

func WaitSecretDisappearOnCluster(cluster, namespace, name string)

WaitSecretDisappearOnCluster wait secret disappear on cluster until timeout.

func WaitSecretDisappearOnClusters added in v1.2.0 

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

WaitSecretDisappearOnClusters wait service disappear on member clusters until timeout.

func WaitSecretPresentOnClusterFitWith added in v1.2.0 

func WaitSecretPresentOnClusterFitWith(cluster, namespace, name string, fit func(secret *corev1.Secret) bool)

WaitSecretPresentOnClusterFitWith wait secret present on member cluster sync with fit func.

func WaitSecretPresentOnClustersFitWith added in v1.2.0 

func WaitSecretPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(secret *corev1.Secret) bool)

WaitSecretPresentOnClustersFitWith wait secret present on clusters sync with fit func.

func WaitServiceDisappearOnCluster added in v1.0.0 

func WaitServiceDisappearOnCluster(cluster, namespace, name string)

WaitServiceDisappearOnCluster wait service disappear on cluster until timeout.

func WaitServiceDisappearOnClusters added in v1.0.0 

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

WaitServiceDisappearOnClusters wait service disappear on member clusters until timeout.

func WaitServicePresentOnClusterFitWith added in v1.0.0 

func WaitServicePresentOnClusterFitWith(cluster, namespace, name string, fit func(service *corev1.Service) bool)

WaitServicePresentOnClusterFitWith wait service present on member clusters sync with fit func.

func WaitServicePresentOnClustersFitWith added in v1.0.0 

func WaitServicePresentOnClustersFitWith(clusters []string, namespace, name string, fit func(service *corev1.Service) bool)

WaitServicePresentOnClustersFitWith wait service present on cluster sync with fit func.

func WaitWorkloadDisappearOnCluster added in v1.0.0 

func WaitWorkloadDisappearOnCluster(cluster, namespace, name string)

WaitWorkloadDisappearOnCluster wait workload disappear on cluster until timeout.

func WaitWorkloadDisappearOnClusters added in v1.0.0 

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

WaitWorkloadDisappearOnClusters wait workload disappear on member clusters until timeout.

func WaitWorkloadPresentOnClusterFitWith added in v1.0.0 

func WaitWorkloadPresentOnClusterFitWith(cluster, namespace, name string, fit func(workload *workloadv1alpha1.Workload) bool)

WaitWorkloadPresentOnClusterFitWith wait workload present on member clusters sync with fit func.

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.