framework

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 51 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 ClusterNamesWithSyncMode added in v1.3.0 

func ClusterNamesWithSyncMode(mode clusterv1alpha1.ClusterSyncMode) []string

ClusterNamesWithSyncMode will return member clusters' names which matches the sync mode.

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 CreateClusterOverridePolicy added in v1.1.6 

func CreateClusterOverridePolicy(client karmada.Interface, policy *policyv1alpha1.ClusterOverridePolicy)

CreateClusterOverridePolicy create ClusterOverridePolicy with karmada 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 CreateCronFederatedHPA added in v1.7.0 

func CreateCronFederatedHPA(client karmada.Interface, fhpa *autoscalingv1alpha1.CronFederatedHPA)

CreateCronFederatedHPA create CronFederatedHPA with karmada client.

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 CreateFederatedHPA added in v1.7.0 

func CreateFederatedHPA(client karmada.Interface, fhpa *autoscalingv1alpha1.FederatedHPA)

CreateFederatedHPA create FederatedHPA with karmada client.

func CreateFederatedResourceQuota added in v1.2.0 

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

CreateFederatedResourceQuota create FederatedResourceQuota with karmada client.

func CreateHPA added in v1.8.0 

func CreateHPA(client kubernetes.Interface, hpa *autoscalingv2.HorizontalPodAutoscaler)

CreateHPA create HPA.

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 CreateMultiClusterService added in v1.8.0 

func CreateMultiClusterService(client karmada.Interface, mcs *networkingv1alpha1.MultiClusterService)

CreateMultiClusterService creates MultiClusterService with karmada client.

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 CreatePVC added in v1.3.0 

func CreatePVC(client kubernetes.Interface, pvc *corev1.PersistentVolumeClaim)

CreatePVC create PersistentVolumeClaim.

func CreatePod added in v1.0.0 

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

CreatePod create Pod.

func CreatePodDisruptionBudget added in v1.5.0 

func CreatePodDisruptionBudget(client kubernetes.Interface, pdb *policyv1.PodDisruptionBudget)

CreatePodDisruptionBudget creates PodDisruptionBudget.

func CreatePropagationPolicy 

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

CreatePropagationPolicy create PropagationPolicy with karmada client.

func CreateResourceInterpreterCustomization added in v1.4.0 

func CreateResourceInterpreterCustomization(client karmada.Interface, customization *configv1alpha1.ResourceInterpreterCustomization)

CreateResourceInterpreterCustomization creates ResourceInterpreterCustomization with karmada client.

func CreateResourceRegistry added in v1.3.0 

func CreateResourceRegistry(client karmada.Interface, rr *searchv1alpha1.ResourceRegistry)

CreateResourceRegistry create ResourceRegistry with karmada client.

func CreateRole added in v1.4.0 

func CreateRole(client kubernetes.Interface, role *rbacv1.Role)

CreateRole create role.

func CreateRoleBinding added in v1.4.0 

func CreateRoleBinding(client kubernetes.Interface, roleBinding *rbacv1.RoleBinding)

CreateRoleBinding create roleBinding.

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 creates Workload with dynamic client

func DeleteClusterLabels added in v1.3.3 

func DeleteClusterLabels(client karmada.Interface, clusterName string, labels map[string]string)

DeleteClusterLabels deletes cluster labels if it exists.

func DeleteResourceInterpreterCustomization added in v1.4.0 

func DeleteResourceInterpreterCustomization(client karmada.Interface, name string)

DeleteResourceInterpreterCustomization deletes ResourceInterpreterCustomization with karmada 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 FetchCluster added in v1.4.0 

func FetchCluster(client karmada.Interface, clusterName string) (*clusterv1alpha1.Cluster, error)

FetchCluster will fetch member cluster by name.

func GetAnyResourceOrFail added in v1.3.0 

func GetAnyResourceOrFail(client dynamic.ResourceInterface) *unstructured.Unstructured

GetAnyResourceOrFail list resources and return anyone. Failed if listing empty.

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 GetResourceNames added in v1.3.0 

func GetResourceNames(client dynamic.ResourceInterface) sets.Set[string]

GetResourceNames list resources and return their names.

func GetWorkload added in v1.0.0 

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

GetWorkload gets Workload with dynamic client.

func InitClusterInformation 

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

InitClusterInformation init the E2E test's cluster information.

func LoadRESTClientConfig added in v1.4.0 

func LoadRESTClientConfig(kubeconfig string, context string) (*rest.Config, error)

LoadRESTClientConfig creates a rest.Config using the passed kubeconfig. If context is empty, current context in kubeconfig will be used.

func PatchClusterPropagationPolicy added in v1.5.0 

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

PatchClusterPropagationPolicy patch ClusterPropagationPolicy with karmada client.

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 RemoveClusterOverridePolicy added in v1.1.6 

func RemoveClusterOverridePolicy(client karmada.Interface, name string)

RemoveClusterOverridePolicy delete ClusterOverridePolicy with karmada 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 RemoveCronFederatedHPA added in v1.7.0 

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

RemoveCronFederatedHPA delete CronFederatedHPA with karmada client.

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 RemoveFederatedHPA added in v1.7.0 

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

RemoveFederatedHPA delete FederatedHPA with karmada client.

func RemoveFederatedResourceQuota added in v1.2.0 

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

RemoveFederatedResourceQuota delete FederatedResourceQuota with karmada client.

func RemoveHPA added in v1.8.0 

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

RemoveHPA delete HPA.

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 RemoveMultiClusterService added in v1.8.0 

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

RemoveMultiClusterService deletes MultiClusterService with karmada client.

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 RemovePVC added in v1.3.0 

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

RemovePVC delete PersistentVolumeClaim.

func RemovePod added in v1.0.0 

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

RemovePod delete Pod.

func RemovePodDisruptionBudget added in v1.5.0 

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

RemovePodDisruptionBudget deletes PodDisruptionBudget.

func RemovePropagationPolicy 

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

RemovePropagationPolicy delete PropagationPolicy with karmada client.

func RemoveResourceRegistry added in v1.3.0 

func RemoveResourceRegistry(client karmada.Interface, name string)

RemoveResourceRegistry delete ResourceRegistry with karmada client.

func RemoveRole added in v1.4.0 

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

RemoveRole delete role.

func RemoveRoleBinding added in v1.4.0 

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

RemoveRoleBinding delete roleBinding.

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 deletes 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 SetClusterRegion added in v1.5.0 

func SetClusterRegion(c client.Client, clusterName string, regionName string) error

SetClusterRegion sets .Spec.Region field for Cluster object.

func UpdateClusterLabels added in v1.3.3 

func UpdateClusterLabels(client karmada.Interface, clusterName string, labels map[string]string)

UpdateClusterLabels updates cluster labels.

func UpdateClusterPropagationPolicy added in v1.4.0 

func UpdateClusterPropagationPolicy(client karmada.Interface, name string, resourceSelectors []policyv1alpha1.ResourceSelector)

UpdateClusterPropagationPolicy update ClusterPropagationPolicy resourceSelectors with karmada client.

func UpdateClusterPropagationPolicyWithSpec added in v1.5.0 

func UpdateClusterPropagationPolicyWithSpec(client karmada.Interface, name string, policySpec policyv1alpha1.PropagationSpec)

UpdateClusterPropagationPolicyWithSpec update PropagationSpec with karmada client.

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 UpdateCronFederatedHPAWithRule added in v1.7.0 

func UpdateCronFederatedHPAWithRule(client karmada.Interface, namespace, name string, rule []autoscalingv1alpha1.CronFederatedHPARule)

UpdateCronFederatedHPAWithRule update CronFederatedHPA with karmada client.

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 UpdateDeploymentLabels added in v1.8.0 

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

UpdateDeploymentLabels update deployment's labels.

func UpdateDeploymentPaused added in v1.4.0 

func UpdateDeploymentPaused(client kubernetes.Interface, deployment *appsv1.Deployment, paused bool)

UpdateDeploymentPaused update deployment's paused.

func UpdateDeploymentReplicas 

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

UpdateDeploymentReplicas update deployment's replicas.

func UpdateDeploymentServiceAccountName added in v1.3.5 

func UpdateDeploymentServiceAccountName(client kubernetes.Interface, deployment *appsv1.Deployment, serviceAccountName string)

UpdateDeploymentServiceAccountName update deployment's serviceAccountName.

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 UpdateMultiClusterService added in v1.8.0 

func UpdateMultiClusterService(client karmada.Interface, mcs *networkingv1alpha1.MultiClusterService)

UpdateMultiClusterService updates MultiClusterService with karmada client.

func UpdateNamespaceLabels added in v1.8.0 

func UpdateNamespaceLabels(client kubernetes.Interface, namespace *corev1.Namespace, labels map[string]string)

UpdateNamespaceLabels update namespace's labels.

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 UpdatePropagationPolicyWithSpec added in v1.5.0 

func UpdatePropagationPolicyWithSpec(client karmada.Interface, namespace, name string, policySpec policyv1alpha1.PropagationSpec)

UpdatePropagationPolicyWithSpec update PropagationSpec with karmada client.

func UpdateResourceRegistry added in v1.3.0 

func UpdateResourceRegistry(client karmada.Interface, rr *searchv1alpha1.ResourceRegistry)

UpdateResourceRegistry patch ResourceRegistry with karmada client.

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 updates Workload with dynamic client

func WaitCRDDisappearedOnClusters 

func WaitCRDDisappearedOnClusters(clusters []string, crdName string)

WaitCRDDisappearedOnClusters wait CustomResourceDefinition disappear on clusters until timeout.

func WaitCRDFitWith added in v1.9.0 

func WaitCRDFitWith(client dynamic.Interface, crdName string, fit func(crd *apiextensionsv1.CustomResourceDefinition) bool)

WaitCRDFitWith wait crd fit with util 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 WaitClusterResourceBindingFitWith added in v1.9.0 

func WaitClusterResourceBindingFitWith(client karmada.Interface, name string, fit func(clusterResourceBinding *workv1alpha2.ClusterResourceBinding) bool)

WaitClusterResourceBindingFitWith wait clusterResourceBinding fit with util timeout

func WaitClusterRoleBindingDisappearOnCluster added in v1.4.0 

func WaitClusterRoleBindingDisappearOnCluster(cluster, name string)

WaitClusterRoleBindingDisappearOnCluster wait clusterRoleBinding disappear on cluster until timeout.

func WaitClusterRoleBindingDisappearOnClusters added in v1.4.0 

func WaitClusterRoleBindingDisappearOnClusters(clusters []string, name string)

WaitClusterRoleBindingDisappearOnClusters wait clusterRoleBinding disappear on member clusters until timeout.

func WaitClusterRoleBindingPresentOnClusterFitWith added in v1.4.0 

func WaitClusterRoleBindingPresentOnClusterFitWith(cluster, name string, fit func(clusterRoleBinding *rbacv1.ClusterRoleBinding) bool)

WaitClusterRoleBindingPresentOnClusterFitWith wait clusterRoleBinding present on member cluster sync with fit func.

func WaitClusterRoleBindingPresentOnClustersFitWith added in v1.4.0 

func WaitClusterRoleBindingPresentOnClustersFitWith(clusters []string, name string, fit func(clusterRoleBinding *rbacv1.ClusterRoleBinding) bool)

WaitClusterRoleBindingPresentOnClustersFitWith wait clusterRoleBinding present on clusters sync with fit func.

func WaitClusterRoleDisappearOnCluster added in v1.4.0 

func WaitClusterRoleDisappearOnCluster(cluster, name string)

WaitClusterRoleDisappearOnCluster wait clusterRole disappear on cluster until timeout.

func WaitClusterRoleDisappearOnClusters added in v1.4.0 

func WaitClusterRoleDisappearOnClusters(clusters []string, name string)

WaitClusterRoleDisappearOnClusters wait clusterRole disappear on member clusters until timeout.

func WaitClusterRoleGetByClientFitWith added in v1.4.0 

func WaitClusterRoleGetByClientFitWith(client kubernetes.Interface, name string, fit func(clusterRole *rbacv1.ClusterRole) bool)

WaitClusterRoleGetByClientFitWith wait clusterRole get by client fit with func.

func WaitClusterRolePresentOnClusterFitWith added in v1.4.0 

func WaitClusterRolePresentOnClusterFitWith(cluster, name string, fit func(clusterRole *rbacv1.ClusterRole) bool)

WaitClusterRolePresentOnClusterFitWith wait clusterRole present on member cluster sync with fit func.

func WaitClusterRolePresentOnClustersFitWith added in v1.4.0 

func WaitClusterRolePresentOnClustersFitWith(clusters []string, name string, fit func(clusterRole *rbacv1.ClusterRole) bool)

WaitClusterRolePresentOnClustersFitWith wait clusterRole present on clusters sync with fit func.

func WaitConfigMapDisappearOnCluster added in v1.7.0 

func WaitConfigMapDisappearOnCluster(cluster, namespace, name string)

WaitConfigMapDisappearOnCluster wait configmap disappear on cluster until timeout.

func WaitConfigMapDisappearOnClusters added in v1.7.0 

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

WaitConfigMapDisappearOnClusters wait configmap disappear on member clusters until timeout.

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 WaitDeploymentFitWith added in v1.9.0 

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

WaitDeploymentFitWith wait deployment sync with fit func.

func WaitDeploymentGetByClientFitWith added in v1.4.0 

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

WaitDeploymentGetByClientFitWith wait deployment get by client fit with func.

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 WaitDeploymentReplicasFitWith added in v1.7.0 

func WaitDeploymentReplicasFitWith(clusters []string, namespace, name string, expectReplicas int)

WaitDeploymentReplicasFitWith wait deployment replicas get by client fit with expected replicas.

func WaitDeploymentStatus added in v1.7.0 

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

WaitDeploymentStatus wait the deployment on the cluster to have the specified replicas

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 WaitMultiClusterServicePresentOnClustersFitWith added in v1.8.0 

func WaitMultiClusterServicePresentOnClustersFitWith(client karmada.Interface, namespace, name string, fit func(mcs *networkingv1alpha1.MultiClusterService) bool)

WaitMultiClusterServicePresentOnClustersFitWith waits MultiClusterService 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 WaitPVCDisappearOnCluster added in v1.3.0 

func WaitPVCDisappearOnCluster(cluster, namespace, name string)

WaitPVCDisappearOnCluster wait PersistentVolumeClaim disappear on cluster until timeout.

func WaitPVCDisappearOnClusters added in v1.3.0 

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

WaitPVCDisappearOnClusters Wait for the PersistentVolumeClaim to disappear on member clusters until timeout.

func WaitPVCPresentOnClusterFitWith added in v1.3.0 

func WaitPVCPresentOnClusterFitWith(cluster, namespace, name string, fit func(pvc *corev1.PersistentVolumeClaim) bool)

WaitPVCPresentOnClusterFitWith wait PersistentVolumeClaim present on member cluster sync with fit func.

func WaitPVCPresentOnClustersFitWith added in v1.3.0 

func WaitPVCPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(pvc *corev1.PersistentVolumeClaim) bool)

WaitPVCPresentOnClustersFitWith wait PersistentVolumeClaim present on clusters sync with fit func.

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 WaitPodMetricsReady added in v1.9.0 

func WaitPodMetricsReady(kubeClient kubernetes.Interface, karmadaClient karmada.Interface, cluster, namespace, name string)

WaitPodMetricsReady wait podMetrics to be ready.

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 WaitResourceBindingFitWith added in v1.9.0 

func WaitResourceBindingFitWith(client karmada.Interface, namespace, name string, fit func(resourceBinding *workv1alpha2.ResourceBinding) bool)

WaitResourceBindingFitWith wait resourceBinding fit with util timeout

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 WaitRoleBindingDisappearOnCluster added in v1.4.0 

func WaitRoleBindingDisappearOnCluster(cluster, namespace, name string)

WaitRoleBindingDisappearOnCluster wait roleBinding disappear on cluster until timeout.

func WaitRoleBindingDisappearOnClusters added in v1.4.0 

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

WaitRoleBindingDisappearOnClusters wait roleBinding disappear on member clusters until timeout.

func WaitRoleBindingPresentOnClusterFitWith added in v1.4.0 

func WaitRoleBindingPresentOnClusterFitWith(cluster, namespace, name string, fit func(roleBinding *rbacv1.RoleBinding) bool)

WaitRoleBindingPresentOnClusterFitWith wait roleBinding present on member cluster sync with fit func.

func WaitRoleBindingPresentOnClustersFitWith added in v1.4.0 

func WaitRoleBindingPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(roleBinding *rbacv1.RoleBinding) bool)

WaitRoleBindingPresentOnClustersFitWith wait robeBinding present on clusters sync with fit func.

func WaitRoleDisappearOnCluster added in v1.4.0 

func WaitRoleDisappearOnCluster(cluster, namespace, name string)

WaitRoleDisappearOnCluster wait role disappear on cluster until timeout.

func WaitRoleDisappearOnClusters added in v1.4.0 

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

WaitRoleDisappearOnClusters wait role disappear on member clusters until timeout.

func WaitRolePresentOnClusterFitWith added in v1.4.0 

func WaitRolePresentOnClusterFitWith(cluster, namespace, name string, fit func(role *rbacv1.Role) bool)

WaitRolePresentOnClusterFitWith wait role present on member cluster sync with fit func.

func WaitRolePresentOnClustersFitWith added in v1.4.0 

func WaitRolePresentOnClustersFitWith(clusters []string, namespace, name string, fit func(role *rbacv1.Role) bool)

WaitRolePresentOnClustersFitWith wait role present on clusters sync with fit func.

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 WaitServiceAccountDisappearOnCluster added in v1.3.5 

func WaitServiceAccountDisappearOnCluster(cluster, namespace, name string)

WaitServiceAccountDisappearOnCluster wait sa disappear on cluster until timeout.

func WaitServiceAccountDisappearOnClusters added in v1.3.5 

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

WaitServiceAccountDisappearOnClusters wait sa disappear on member clusters until timeout.

func WaitServiceAccountPresentOnClusterFitWith added in v1.3.5 

func WaitServiceAccountPresentOnClusterFitWith(cluster, namespace, name string, fit func(sa *corev1.ServiceAccount) bool)

WaitServiceAccountPresentOnClusterFitWith wait sa present on member clusters sync with fit func.

func WaitServiceAccountPresentOnClustersFitWith added in v1.3.5 

func WaitServiceAccountPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(sa *corev1.ServiceAccount) bool)

WaitServiceAccountPresentOnClustersFitWith wait sa present on cluster 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 waits 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 waits workload present on member cluster sync with fit func.

func WaitWorkloadPresentOnClustersFitWith added in v1.4.0 

func WaitWorkloadPresentOnClustersFitWith(clusters []string, namespace, name string, fit func(workload *workloadv1alpha1.Workload) bool)

WaitWorkloadPresentOnClustersFitWith waits workload present on member clusters sync with fit func.

Types

type KarmadactlBuilder added in v1.8.0 

type KarmadactlBuilder struct {
	// contains filtered or unexported fields
}

KarmadactlBuilder is a builder to run karmadactl.

func NewKarmadactlCommand added in v1.8.0 

func NewKarmadactlCommand(kubeConfig, karmadaContext, karmadactlPath, namespace string, timeout time.Duration, args ...string) *KarmadactlBuilder

NewKarmadactlCommand creates a new KarmadactlBuilder.

func (*KarmadactlBuilder) ExecOrDie added in v1.8.0 

func (k *KarmadactlBuilder) ExecOrDie() (string, error)

ExecOrDie executes the karmadactl executable and returns the stdout.

type TestKubeconfig added in v1.8.0 

type TestKubeconfig struct {
	KubeConfig     string
	KarmadaContext string
	KarmadactlPath string
	Namespace      string
}

TestKubeconfig contains the information of a test kubeconfig.

func NewTestKubeconfig added in v1.8.0 

func NewTestKubeconfig(kubeConfig, karmadaContext, karmadactlpath, namespace string) *TestKubeconfig

NewTestKubeconfig creates a new TestKubeconfig.

func (*TestKubeconfig) KarmadactlCmd added in v1.8.0 

func (tk *TestKubeconfig) KarmadactlCmd(args ...string) *exec.Cmd

KarmadactlCmd runs the karmadactl executable through the wrapper script.

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.