fix spelling errors

Signed-off-by: whitewindmills <[email protected]>

cmd/controller-manager/app/controllermanager.go

@@ -566,7 +566,7 @@ func startFederatedHorizontalPodAutoscalerController(ctx controllerscontext.Cont
 		EventRecorder:                     ctx.Mgr.GetEventRecorderFor(federatedhpa.ControllerName),
 		RESTMapper:                        ctx.Mgr.GetRESTMapper(),
 		DownscaleStabilisationWindow:      ctx.Opts.HPAControllerConfiguration.HorizontalPodAutoscalerDownscaleStabilizationWindow.Duration,
-		HorizontalPodAutoscalerSyncPeroid: ctx.Opts.HPAControllerConfiguration.HorizontalPodAutoscalerSyncPeriod.Duration,
+		HorizontalPodAutoscalerSyncPeriod: ctx.Opts.HPAControllerConfiguration.HorizontalPodAutoscalerSyncPeriod.Duration,
 		ReplicaCalc:                       replicaCalculator,
 		ClusterScaleClientSetFunc:         util.NewClusterScaleClientSet,
 		TypedInformerManager:              typedmanager.GetInstance(),

docs/proposals/service-discovery/README.md

@@ -165,7 +165,7 @@ The optimization design for the MultiClusterService API needs to be further iter
 
 Before delving into the specific design details, let's first take a look from the user's perspective at what preparations they need to make.
 
-1. The user creates a foo Deployment and Service on the Karmad control panel, and creates a PropagationPolicy to distribute them into the member cluster member1.
+1. The user creates a foo Deployment and Service on the Karmada control panel, and creates a PropagationPolicy to distribute them into the member cluster member1.
 
 ![image](statics/user-operation-01.png)
 

operator/pkg/certs/store.go

@@ -13,7 +13,7 @@ type CertStore interface {
 	AddCert(cert *KarmadaCert)
 	GetCert(name string) *KarmadaCert
 	CertList() []*KarmadaCert
-	LoadCertFormSercret(sercret *corev1.Secret) error
+	LoadCertFormSecret(secret *corev1.Secret) error
 }
 
 type splitToPairNameFunc func(name string) string
@@ -65,7 +65,7 @@ func (store *KarmadaCertStore) GetCert(name string) *KarmadaCert {
 	return nil
 }
 
-// CertList lists all of karmada certs in the cert chache.
+// CertList lists all of karmada certs in the cert cache.
 func (store *KarmadaCertStore) CertList() []*KarmadaCert {
 	certs := make([]*KarmadaCert, 0, len(store.certs))
 
@@ -76,15 +76,15 @@ func (store *KarmadaCertStore) CertList() []*KarmadaCert {
 	return certs
 }
 
-// LoadCertFormSercret loads a set of certs form k8s secret resource. we get cert
+// LoadCertFormSecret loads a set of certs form k8s secret resource. we get cert
 // cache key by calling the pairNameFunc function. if the secret data key suffix is ".crt",
 // it be considered cert data. if the suffix is ".key", it be considered cert key data.
-func (store *KarmadaCertStore) LoadCertFormSercret(sercret *corev1.Secret) error {
-	if len(sercret.Data) == 0 {
+func (store *KarmadaCertStore) LoadCertFormSecret(secret *corev1.Secret) error {
+	if len(secret.Data) == 0 {
 		return fmt.Errorf("cert data is empty")
 	}
 
-	for name, data := range sercret.Data {
+	for name, data := range secret.Data {
 		pairName := store.pairNameFunc(name)
 		kc := store.GetCert(pairName)
 		if kc == nil {

operator/pkg/constants/constants.go

@@ -105,7 +105,7 @@ const (
 	// KarmadaOperatorLabelKeyName defines a label key used by all resources created by karmada operator
 	KarmadaOperatorLabelKeyName = "app.kubernetes.io/managed-by"
 
-	// APIServiceName defines the karmada aggregated apiserver APISerivce resource name.
+	// APIServiceName defines the karmada aggregated apiserver APIService resource name.
 	APIServiceName = "v1alpha1.cluster.karmada.io"
 )
 

operator/pkg/tasks/init/cert.go

@@ -46,7 +46,7 @@ func skipCerts(d workflow.RunData) (bool, error) {
 		return false, nil
 	}
 
-	if err := data.LoadCertFormSercret(secret); err != nil {
+	if err := data.LoadCertFormSecret(secret); err != nil {
 		return false, err
 	}
 

operator/pkg/tasks/init/etcd.go

@@ -53,7 +53,7 @@ func runDeployEtcd(r workflow.RunData) error {
 	}
 
 	if cfg.Etcd.Local == nil {
-		return errors.New("unexpect empty etcd local configuration")
+		return errors.New("unexpected empty etcd local configuration")
 	}
 
 	err := etcd.EnsureKarmadaEtcd(data.RemoteClient(), cfg.Etcd.Local, data.GetName(), data.GetNamespace())

operator/pkg/tasks/init/karmadaresource.go

@@ -102,7 +102,7 @@ func runCrds(r workflow.RunData) error {
 
 	cert := data.GetCert(constants.CaCertAndKeyName)
 	if len(cert.CertData()) == 0 {
-		return errors.New("unexpect empty ca cert data")
+		return errors.New("unexpected empty ca cert data")
 	}
 
 	caBase64 := base64.StdEncoding.EncodeToString(cert.CertData())
@@ -149,7 +149,7 @@ func patchCrds(crdsClient *crdsclient.Clientset, patchPath string, caBundle stri
 		}
 
 		crdPath := path.Join(patchPath, file.Name())
-		crdBytes, err := util.RelpaceYamlForReg(crdPath, caBundle, reg)
+		crdBytes, err := util.ReplaceYamlForReg(crdPath, caBundle, reg)
 		if err != nil {
 			return err
 		}
@@ -171,7 +171,7 @@ func runWebhookConfiguration(r workflow.RunData) error {
 
 	cert := data.GetCert(constants.CaCertAndKeyName)
 	if len(cert.CertData()) == 0 {
-		return errors.New("unexpect empty ca cert data for webhookConfiguration")
+		return errors.New("unexpected empty ca cert data for webhookConfiguration")
 	}
 
 	caBase64 := base64.StdEncoding.EncodeToString(cert.CertData())

operator/pkg/tasks/init/upload.go

@@ -168,7 +168,7 @@ func runUploadCerts(r workflow.RunData) error {
 	klog.V(4).InfoS("[upload-certs] Running upload-certs task", "karmada", klog.KObj(data))
 
 	if len(data.CertList()) == 0 {
-		return errors.New("there is no certs in store, please reload crets to store")
+		return errors.New("there is no certs in store, please reload certs to store")
 	}
 	return nil
 }

operator/pkg/tasks/init/wait.go

@@ -78,22 +78,22 @@ func runWaitControlPlane(r workflow.RunData) error {
 	return nil
 }
 
-func newWaitControlPlaneSubTask(component string, lables labels.Set) workflow.Task {
+func newWaitControlPlaneSubTask(component string, ls labels.Set) workflow.Task {
 	return workflow.Task{
 		Name: component,
-		Run:  runWaitControlPlaneSubTask(component, lables),
+		Run:  runWaitControlPlaneSubTask(component, ls),
 	}
 }
 
-func runWaitControlPlaneSubTask(component string, lables labels.Set) func(r workflow.RunData) error {
+func runWaitControlPlaneSubTask(component string, ls labels.Set) func(r workflow.RunData) error {
 	return func(r workflow.RunData) error {
 		data, ok := r.(InitData)
 		if !ok {
 			return errors.New("wait-controlPlane task invoked with an invalid data struct")
 		}
 
 		waiter := apiclient.NewKarmadaWaiter(nil, data.RemoteClient(), componentBeReadyTimeout)
-		if err := waiter.WaitForSomePods(lables.String(), data.GetNamespace(), 1); err != nil {
+		if err := waiter.WaitForSomePods(ls.String(), data.GetNamespace(), 1); err != nil {
 			return fmt.Errorf("waiting for %s to ready timeout, err: %w", component, err)
 		}
 

operator/pkg/util/apiclient/idempotency.go

@@ -196,7 +196,7 @@ func CreateCustomResourceDefinitionIfNeed(client *crdsclient.Clientset, obj *api
 	return nil
 }
 
-// PatchCustomResourceDefinition patchs a crd resource.
+// PatchCustomResourceDefinition patches a crd resource.
 func PatchCustomResourceDefinition(client *crdsclient.Clientset, name string, data []byte) error {
 	crd := client.ApiextensionsV1().CustomResourceDefinitions()
 	if _, err := crd.Patch(context.TODO(), name, types.StrategicMergePatchType, data, metav1.PatchOptions{}); err != nil {

operator/pkg/util/apiclient/wait.go

@@ -41,7 +41,7 @@ type KarmadaWaiter struct {
 	timeout       time.Duration
 }
 
-// NewKarmadaWaiter reurn a karmada waiter, the rest config is to create crd client or aggregate client.
+// NewKarmadaWaiter returns a karmada waiter, the rest config is to create crd client or aggregate client.
 func NewKarmadaWaiter(config *rest.Config, client clientset.Interface, timeout time.Duration) Waiter {
 	return &KarmadaWaiter{
 		karmadaConfig: config,
@@ -169,8 +169,8 @@ func isPodRunning(pod corev1.Pod) bool {
 		return false
 	}
 
-	for _, condtion := range pod.Status.Conditions {
-		if condtion.Type == corev1.PodReady && condtion.Status == corev1.ConditionTrue {
+	for _, condition := range pod.Status.Conditions {
+		if condition.Type == corev1.PodReady && condition.Status == corev1.ConditionTrue {
 			return true
 		}
 	}

operator/pkg/util/patcher/pather.go

@@ -76,7 +76,7 @@ func (p *Patcher) ForDeployment(deployment *appsv1.Deployment) {
 
 		overrideArgs := map[string]string{}
 
-		// merge featureGates and build to an argurment.
+		// merge featureGates and build to an argument.
 		if len(p.featureGates) != 0 {
 			baseFeatureGates := map[string]bool{}
 
@@ -147,7 +147,7 @@ func parseFeatrueGatesArgumentToMap(featureGates string) map[string]bool {
 
 	featureGatesMap := map[string]bool{}
 	for _, featureGate := range featureGateSlice {
-		key, val, err := parseFeatrueGate(featureGate)
+		key, val, err := parseFeatureGate(featureGate)
 		if err != nil {
 			continue
 		}
@@ -221,7 +221,7 @@ func parseArgument(arg string) (string, string, error) {
 	return keyvalSlice[0], keyvalSlice[1], nil
 }
 
-func parseFeatrueGate(featureGate string) (string, bool, error) {
+func parseFeatureGate(featureGate string) (string, bool, error) {
 	if !strings.Contains(featureGate, "=") {
 		return "", false, errors.New("the featureGate should have a '=' between the flag and the value")
 	}

operator/pkg/util/util.go

@@ -169,8 +169,8 @@ func ReadYamlFile(path string) ([]byte, error) {
 	return yaml.YAMLToJSON(data)
 }
 
-// RelpaceYamlForReg replace content of yaml file with a Regexp
-func RelpaceYamlForReg(path, destResource string, reg *regexp.Regexp) ([]byte, error) {
+// ReplaceYamlForReg replace content of yaml file with a Regexp
+func ReplaceYamlForReg(path, destResource string, reg *regexp.Regexp) ([]byte, error) {
 	data, err := os.ReadFile(path)
 	if err != nil {
 		return nil, err

pkg/apis/cluster/v1alpha1/well_known_constants.go

@@ -2,7 +2,7 @@ package v1alpha1
 
 const (
 	// TaintClusterUnscheduler will be added when cluster becomes unschedulable
-	// and removed when cluster becomes scheduable.
+	// and removed when cluster becomes schedulable.
 	TaintClusterUnscheduler = "cluster.karmada.io/unschedulable"
 	// TaintClusterNotReady will be added when cluster is not ready
 	// and removed when cluster becomes ready.

pkg/controllers/federatedhpa/federatedhpa_controller.go

@@ -74,7 +74,7 @@ type FederatedHPAController struct {
 
 	monitor monitor.Monitor
 
-	HorizontalPodAutoscalerSyncPeroid time.Duration
+	HorizontalPodAutoscalerSyncPeriod time.Duration
 	DownscaleStabilisationWindow      time.Duration
 	// Latest unstabilized recommendations for each autoscaler.
 	recommendations     map[string][]timestampedRecommendation
@@ -166,7 +166,7 @@ func (c *FederatedHPAController) Reconcile(ctx context.Context, req controllerru
 		return controllerruntime.Result{}, err
 	}
 
-	return controllerruntime.Result{RequeueAfter: c.HorizontalPodAutoscalerSyncPeroid}, nil
+	return controllerruntime.Result{RequeueAfter: c.HorizontalPodAutoscalerSyncPeriod}, nil
 }
 
 //nolint:gocyclo

pkg/controllers/status/work_status_controller_test.go

@@ -555,7 +555,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 		pod                       *corev1.Pod
 		raw                       []byte
 		controllerWithoutInformer bool
-		workWithRigntNS           bool
+		workWithRightNS           bool
 		expectedError             bool
 		workWithDeletionTimestamp bool
 		wrongWorkNS               bool
@@ -566,7 +566,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             true,
 		},
 		{
@@ -575,7 +575,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             true,
 		},
 		{
@@ -584,15 +584,15 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: false,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             true,
 		},
 		{
 			name:                      "obj not found in informer, wrong dynamicClientSet without pod",
 			obj:                       newPodObj("karmada-es-cluster"),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             false,
 		},
 		{
@@ -601,7 +601,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName, true),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             false,
 		},
 		{
@@ -610,7 +610,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           false,
+			workWithRightNS:           false,
 			expectedError:             false,
 		},
 		{
@@ -619,7 +619,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod1","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             true,
 		},
 		{
@@ -628,7 +628,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			pod:                       newPod(workNs, workName),
 			raw:                       []byte(`{"apiVersion":"v1","kind":"Pod","metadata":{"name":"pod","namespace":"default"}}`),
 			controllerWithoutInformer: true,
-			workWithRigntNS:           true,
+			workWithRightNS:           true,
 			expectedError:             true,
 			wrongWorkNS:               true,
 		},
@@ -656,7 +656,7 @@ func TestWorkStatusController_syncWorkStatus(t *testing.T) {
 			}
 
 			var work *workv1alpha1.Work
-			if tt.workWithRigntNS {
+			if tt.workWithRightNS {
 				work = testhelper.NewWork(workName, workNs, workUID, tt.raw)
 			} else {
 				work = testhelper.NewWork(workName, fmt.Sprintf("%v-test", workNs), workUID, tt.raw)

pkg/karmadactl/addons/disable.go

@@ -29,7 +29,7 @@ var (
 	# Specify the Karmada control plane kubeconfig
 	%[1]s disable karmada-search --karmada-kubeconfig /etc/karmada/karmada-apiserver.config
 
-	# Sepcify the namespace where Karmada components are installed
+	# Specify the namespace where Karmada components are installed
 	%[1]s disable karmada-search --namespace karmada-system
 	`)
 )

pkg/karmadactl/addons/enable.go

@@ -34,7 +34,7 @@ var (
 	# Specify the karmada-search image
 	%[1]s enable karmada-search --karmada-search-image docker.io/karmada/karmada-search:latest
 
-	# Sepcify the namespace where Karmada components are installed
+	# Specify the namespace where Karmada components are installed
 	%[1]s enable karmada-search --namespace karmada-system
 	`)
 )

pkg/karmadactl/addons/init/global.go

@@ -19,7 +19,7 @@ type GlobalCommandOptions struct {
 	KarmadaConfig  string
 	KarmadaContext string
 
-	// Namespace holds the namespace where Karmada components intalled
+	// Namespace holds the namespace where Karmada components installed
 	Namespace string
 
 	// Cluster holds the name of member cluster to enable or disable scheduler estimator

pkg/karmadactl/addons/list.go

@@ -23,7 +23,7 @@ var (
 	# Specify the karmada control plane kubeconfig
 	%[1]s list --karmada-kubeconfig /etc/karmada/karmada-apiserver.config
 	
-	# Sepcify the namespace where Karmada components are installed
+	# Specify the namespace where Karmada components are installed
 	%[1]s list --namespace karmada-system
 	`)
 )

pkg/karmadactl/cmdinit/karmada/deploy.go

@@ -104,7 +104,7 @@ func InitKarmadaResources(dir, caBase64, systemNamespace string) error {
 		klog.Exitln(err)
 	}
 
-	if err = createExtralResources(clientSet, dir); err != nil {
+	if err = createExtraResources(clientSet, dir); err != nil {
 		klog.Exitln(err)
 	}
 
@@ -143,7 +143,7 @@ func InitKarmadaBootstrapToken(dir string) (string, error) {
 	return registerCommand, nil
 }
 
-func createExtralResources(clientSet *kubernetes.Clientset, dir string) error {
+func createExtraResources(clientSet *kubernetes.Clientset, dir string) error {
 	// grant view clusterrole with karamda resource permission
 	if err := grantKarmadaPermissionToViewClusterRole(clientSet); err != nil {
 		return err