cleanup: fix some log and error capitalizations

davidxia · davidxia · commit fabfd950b115 · 2019-07-20T18:26:16.000-04:00
Part of kubernetes#15863
diff --git a/cluster/gce/gci/mounter/mounter.go b/cluster/gce/gci/mounter/mounter.go
@@ -79,14 +79,14 @@ func mountInChroot(rootfsPath string, args []string) error {
 	// Mount failed because it is NFS V3 and we need to run rpcBind
 	output, err = exec.Command(chrootCmd, rootfsPath, rpcBindCmd, "-w").CombinedOutput()
 	if err != nil {
-		return fmt.Errorf("Mount issued for NFS V3 but unable to run rpcbind:\n Output: %s\n Error: %v", string(output), err)
+		return fmt.Errorf("mount issued for NFS V3 but unable to run rpcbind:\n Output: %s\n Error: %v", string(output), err)
 	}
 
 	// Rpcbind is running, try mounting again
 	output, err = exec.Command(chrootCmd, args...).CombinedOutput()
 
 	if err != nil {
-		return fmt.Errorf("Mount failed for NFS V3 even after running rpcBind %s, %v", string(output), err)
+		return fmt.Errorf("mount failed for NFS V3 even after running rpcBind %s, %v", string(output), err)
 	}
 
 	return nil
diff --git a/cluster/images/etcd/migrate/migrate_client.go b/cluster/images/etcd/migrate/migrate_client.go
@@ -195,12 +195,12 @@ func (e *CombinedEtcdClient) AttachLease(leaseDuration time.Duration) error {
 	defer v3client.Close()
 	objectsResp, err := v3client.KV.Get(ctx, ttlKeysPrefix, clientv3.WithPrefix())
 	if err != nil {
-		return fmt.Errorf("Error while getting objects to attach to the lease")
+		return fmt.Errorf("error while getting objects to attach to the lease")
 	}
 
 	lease, err := v3client.Lease.Grant(ctx, int64(leaseDuration/time.Second))
 	if err != nil {
-		return fmt.Errorf("Error while creating lease: %v", err)
+		return fmt.Errorf("error while creating lease: %v", err)
 	}
 	klog.Infof("Lease with TTL: %v created", lease.TTL)
 
diff --git a/cluster/images/etcd/migrate/migrate_server.go b/cluster/images/etcd/migrate/migrate_server.go
@@ -87,7 +87,7 @@ func (r *EtcdMigrateServer) Start(version *EtcdVersion) error {
 			if err != nil {
 				return fmt.Errorf("error killing etcd: %v", err)
 			}
-			return fmt.Errorf("Timed out waiting for etcd on port %d", r.cfg.port)
+			return fmt.Errorf("timed out waiting for etcd on port %d", r.cfg.port)
 		}
 	}
 }
diff --git a/cluster/images/etcd/migrate/versions.go b/cluster/images/etcd/migrate/versions.go
@@ -111,7 +111,7 @@ type EtcdVersionPair struct {
 func ParseEtcdVersionPair(s string) (*EtcdVersionPair, error) {
 	parts := strings.Split(s, "/")
 	if len(parts) != 2 {
-		return nil, fmt.Errorf("Malformed version file, expected <major>.<minor>.<patch>/<storage> but got %s", s)
+		return nil, fmt.Errorf("malformed version file, expected <major>.<minor>.<patch>/<storage> but got %s", s)
 	}
 	version, err := ParseEtcdVersion(parts[0])
 	if err != nil {
diff --git a/cmd/kube-proxy/app/server_test.go b/cmd/kube-proxy/app/server_test.go
@@ -393,7 +393,7 @@ func TestConfigChange(t *testing.T) {
 	setUp := func() (*os.File, string, error) {
 		tempDir, err := ioutil.TempDir("", "kubeproxy-config-change")
 		if err != nil {
-			return nil, "", fmt.Errorf("Unable to create temporary directory: %v", err)
+			return nil, "", fmt.Errorf("unable to create temporary directory: %v", err)
 		}
 		fullPath := filepath.Join(tempDir, "kube-proxy-config")
 		file, err := os.Create(fullPath)
diff --git a/cmd/kubeadm/app/cmd/alpha/kubelet.go b/cmd/kubeadm/app/cmd/alpha/kubelet.go
@@ -138,10 +138,10 @@ func newCmdKubeletConfigEnableDynamic() *cobra.Command {
 		Example: kubeletConfigEnableDynamicExample,
 		Run: func(cmd *cobra.Command, args []string) {
 			if len(nodeName) == 0 {
-				kubeadmutil.CheckErr(errors.New("The --node-name argument is required"))
+				kubeadmutil.CheckErr(errors.New("the --node-name argument is required"))
 			}
 			if len(kubeletVersionStr) == 0 {
-				kubeadmutil.CheckErr(errors.New("The --kubelet-version argument is required"))
+				kubeadmutil.CheckErr(errors.New("the --kubelet-version argument is required"))
 			}
 
 			kubeletVersion, err := version.ParseSemantic(kubeletVersionStr)
diff --git a/cmd/kubeadm/app/cmd/config.go b/cmd/kubeadm/app/cmd/config.go
@@ -242,7 +242,7 @@ func NewCmdConfigMigrate(out io.Writer) *cobra.Command {
 		`), kubeadmapiv1beta2.SchemeGroupVersion, kubeadmapiv1beta2.SchemeGroupVersion),
 		Run: func(cmd *cobra.Command, args []string) {
 			if len(oldCfgPath) == 0 {
-				kubeadmutil.CheckErr(errors.New("The --old-config flag is mandatory"))
+				kubeadmutil.CheckErr(errors.New("the --old-config flag is mandatory"))
 			}
 
 			oldCfgBytes, err := ioutil.ReadFile(oldCfgPath)
@@ -319,7 +319,7 @@ func NewCmdConfigUploadFromFile(out io.Writer, kubeConfigFile *string) *cobra.Co
 		`), metav1.NamespaceSystem, constants.KubeadmConfigConfigMap),
 		Run: func(cmd *cobra.Command, args []string) {
 			if len(cfgPath) == 0 {
-				kubeadmutil.CheckErr(errors.New("The --config flag is mandatory"))
+				kubeadmutil.CheckErr(errors.New("the --config flag is mandatory"))
 			}
 
 			klog.V(1).Infoln("[config] retrieving ClientSet from file")
diff --git a/cmd/kubeadm/app/cmd/phases/reset/preflight.go b/cmd/kubeadm/app/cmd/phases/reset/preflight.go
@@ -58,7 +58,7 @@ func runPreflight(c workflow.RunData) error {
 			return err
 		}
 		if strings.ToLower(s.Text()) != "y" {
-			return errors.New("Aborted reset operation")
+			return errors.New("aborted reset operation")
 		}
 	}
 
diff --git a/cmd/kubeadm/app/constants/constants.go b/cmd/kubeadm/app/constants/constants.go
@@ -428,7 +428,7 @@ func EtcdSupportedVersion(versionString string) (*version.Version, error) {
 		}
 		return etcdVersion, nil
 	}
-	return nil, errors.Errorf("Unsupported or unknown Kubernetes version(%v)", kubernetesVersion)
+	return nil, errors.Errorf("unsupported or unknown Kubernetes version(%v)", kubernetesVersion)
 }
 
 // GetStaticPodDirectory returns the location on the disk where the Static Pod should be present
diff --git a/cmd/kubeadm/app/constants/constants_test.go b/cmd/kubeadm/app/constants/constants_test.go
@@ -157,7 +157,7 @@ func TestEtcdSupportedVersion(t *testing.T) {
 		{
 			kubernetesVersion: "1.99.0",
 			expectedVersion:   nil,
-			expectedError:     errors.New("Unsupported or unknown Kubernetes version(1.99.0)"),
+			expectedError:     errors.New("unsupported or unknown Kubernetes version(1.99.0)"),
 		},
 		{
 			kubernetesVersion: MinimumControlPlaneVersion.WithPatch(1).String(),
diff --git a/cmd/kubeadm/app/phases/upgrade/prepull.go b/cmd/kubeadm/app/phases/upgrade/prepull.go
@@ -132,7 +132,7 @@ func waitForItemsFromChan(timeoutChan <-chan time.Time, stringChan chan string,
 	for {
 		select {
 		case <-timeoutChan:
-			return errors.New("The prepull operation timed out")
+			return errors.New("the prepull operation timed out")
 		case result := <-stringChan:
 			i++
 			// If the cleanup function errors; error here as well
diff --git a/cmd/kubeadm/app/util/apiclient/idempotency_test.go b/cmd/kubeadm/app/util/apiclient/idempotency_test.go
@@ -158,7 +158,7 @@ func TestMutateConfigMapWithConflict(t *testing.T) {
 		update := action.(core.UpdateAction)
 		if conflict > 0 {
 			conflict--
-			return true, update.GetObject(), apierrors.NewConflict(action.GetResource().GroupResource(), configMapName, errors.New("Conflict"))
+			return true, update.GetObject(), apierrors.NewConflict(action.GetResource().GroupResource(), configMapName, errors.New("conflict"))
 		}
 		return false, update.GetObject(), nil
 	})
diff --git a/cmd/kubelet/app/auth.go b/cmd/kubelet/app/auth.go
@@ -98,10 +98,10 @@ func BuildAuthz(client authorizationclient.SubjectAccessReviewInterface, authz k
 		return authorizerConfig.New()
 
 	case "":
-		return nil, fmt.Errorf("No authorization mode specified")
+		return nil, fmt.Errorf("no authorization mode specified")
 
 	default:
-		return nil, fmt.Errorf("Unknown authorization mode %s", authz.Mode)
+		return nil, fmt.Errorf("unknown authorization mode %s", authz.Mode)
 
 	}
 }
diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go
@@ -418,7 +418,7 @@ func Run(s *options.KubeletServer, kubeDeps *kubelet.Dependencies, stopCh <-chan
 
 func checkPermissions() error {
 	if uid := os.Getuid(); uid != 0 {
-		return fmt.Errorf("Kubelet needs to run as uid `0`. It is being run as %d", uid)
+		return fmt.Errorf("kubelet needs to run as uid `0`. It is being run as %d", uid)
 	}
 	// TODO: Check if kubelet is running in the `initial` user namespace.
 	// http://man7.org/linux/man-pages/man7/user_namespaces.7.html
diff --git a/hack/e2e.go b/hack/e2e.go
@@ -153,7 +153,7 @@ func (t tester) getKubetest(get bool, old time.Duration) (string, error) {
 		log.Printf("The kubetest binary is older than %s.", old)
 	}
 	if t.goPath == "" {
-		return "", fmt.Errorf("Cannot install kubetest until $GOPATH is set")
+		return "", fmt.Errorf("cannot install kubetest until $GOPATH is set")
 	}
 	log.Print("Updating kubetest binary...")
 	cmd := []string{"go", "get", "-u", "k8s.io/test-infra/kubetest"}
diff --git a/hack/e2e_test.go b/hack/e2e_test.go
@@ -138,10 +138,10 @@ func TestParse(t *testing.T) {
 }
 
 func TestLook(t *testing.T) {
-	lpf := errors.New("LookPath failed")
-	sf := errors.New("Stat failed")
-	lpnc := errors.New("LookPath should not be called")
-	snc := errors.New("Stat should not be called")
+	lpf := errors.New("lookPath failed")
+	sf := errors.New("stat failed")
+	lpnc := errors.New("lookPath should not be called")
+	snc := errors.New("stat should not be called")
 	cases := []struct {
 		stat     error
 		lookPath error
@@ -324,15 +324,15 @@ func TestGetKubetest(t *testing.T) {
 			stat: func(p string) (os.FileInfo, error) {
 				// stat
 				if p != c.stat {
-					return nil, fmt.Errorf("Failed to find %s", p)
+					return nil, fmt.Errorf("failed to find %s", p)
 				}
 				return FileInfo{time.Now().Add(c.age * -1)}, nil
 			},
 			lookPath: func(name string) (string, error) {
 				if c.path {
 					return filepath.Join(p, name), nil
 				}
-				return "", fmt.Errorf("Not on path: %s", name)
+				return "", fmt.Errorf("not on path: %s", name)
 			},
 			goPath: c.goPath,
 			wait: func(cmd string, args ...string) error {
diff --git a/pkg/api/testing/compat/compatibility_tester.go b/pkg/api/testing/compat/compatibility_tester.go
@@ -114,17 +114,17 @@ func getJSONValue(data map[string]interface{}, keys ...string) (interface{}, boo
 	// Look up the value
 	value, ok := data[key]
 	if !ok {
-		return nil, false, fmt.Errorf("No key %s found", key)
+		return nil, false, fmt.Errorf("no key %s found", key)
 	}
 
 	// Get the indexed value if an index is specified
 	if index >= 0 {
 		valueSlice, ok := value.([]interface{})
 		if !ok {
-			return nil, false, fmt.Errorf("Key %s did not hold a slice", key)
+			return nil, false, fmt.Errorf("key %s did not hold a slice", key)
 		}
 		if index >= len(valueSlice) {
-			return nil, false, fmt.Errorf("Index %d out of bounds for slice at key: %v", index, key)
+			return nil, false, fmt.Errorf("index %d out of bounds for slice at key: %v", index, key)
 		}
 		value = valueSlice[index]
 	}
@@ -135,7 +135,7 @@ func getJSONValue(data map[string]interface{}, keys ...string) (interface{}, boo
 
 	childData, ok := value.(map[string]interface{})
 	if !ok {
-		return nil, false, fmt.Errorf("Key %s did not hold a map", keys[0])
+		return nil, false, fmt.Errorf("key %s did not hold a map", keys[0])
 	}
 	return getJSONValue(childData, keys[1:]...)
 }
diff --git a/pkg/api/v1/resource/helpers.go b/pkg/api/v1/resource/helpers.go
@@ -148,7 +148,7 @@ func ExtractContainerResourceValue(fs *v1.ResourceFieldSelector, container *v1.C
 		return convertResourceEphemeralStorageToString(container.Resources.Requests.StorageEphemeral(), divisor)
 	}
 
-	return "", fmt.Errorf("Unsupported container resource : %v", fs.Resource)
+	return "", fmt.Errorf("unsupported container resource : %v", fs.Resource)
 }
 
 // convertResourceCPUToString converts cpu value to the format of divisor and returns
diff --git a/pkg/cloudprovider/providers/openstack/openstack_loadbalancer.go b/pkg/cloudprovider/providers/openstack/openstack_loadbalancer.go
@@ -1519,7 +1519,7 @@ func (lbaas *LbaasV2) EnsureLoadBalancerDeleted(ctx context.Context, clusterName
 	if lbaas.opts.ManageSecurityGroups {
 		err := lbaas.EnsureSecurityGroupDeleted(clusterName, service)
 		if err != nil {
-			return fmt.Errorf("Failed to delete Security Group for loadbalancer service %s/%s: %v", service.Namespace, service.Name, err)
+			return fmt.Errorf("failed to delete Security Group for loadbalancer service %s/%s: %v", service.Namespace, service.Name, err)
 		}
 	}
 
@@ -1536,7 +1536,7 @@ func (lbaas *LbaasV2) EnsureSecurityGroupDeleted(clusterName string, service *v1
 			// It is OK when the security group has been deleted by others.
 			return nil
 		}
-		return fmt.Errorf("Error occurred finding security group: %s: %v", lbSecGroupName, err)
+		return fmt.Errorf("error occurred finding security group: %s: %v", lbSecGroupName, err)
 	}
 
 	lbSecGroup := groups.Delete(lbaas.network, lbSecGroupID)
@@ -1567,7 +1567,7 @@ func (lbaas *LbaasV2) EnsureSecurityGroupDeleted(clusterName string, service *v1
 			for _, rule := range secGroupRules {
 				res := rules.Delete(lbaas.network, rule.ID)
 				if res.Err != nil && !isNotFound(res.Err) {
-					return fmt.Errorf("Error occurred deleting security group rule: %s: %v", rule.ID, res.Err)
+					return fmt.Errorf("error occurred deleting security group rule: %s: %v", rule.ID, res.Err)
 				}
 			}
 		}
diff --git a/pkg/controller/certificates/rootcacertpublisher/publisher.go b/pkg/controller/certificates/rootcacertpublisher/publisher.go
@@ -211,11 +211,11 @@ func convertToCM(obj interface{}) (*v1.ConfigMap, error) {
 	if !ok {
 		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
 		if !ok {
-			return nil, fmt.Errorf("Couldn't get object from tombstone %#v", obj)
+			return nil, fmt.Errorf("couldn't get object from tombstone %#v", obj)
 		}
 		cm, ok = tombstone.Obj.(*v1.ConfigMap)
 		if !ok {
-			return nil, fmt.Errorf("Tombstone contained object that is not a ConfigMap %#v", obj)
+			return nil, fmt.Errorf("tombstone contained object that is not a ConfigMap %#v", obj)
 		}
 	}
 	return cm, nil
diff --git a/pkg/controller/certificates/signer/cfssl_signer.go b/pkg/controller/certificates/signer/cfssl_signer.go
@@ -87,7 +87,7 @@ func newCFSSLSigner(caFile, caKeyFile string, client clientset.Interface, certif
 
 	priv, err := helpers.ParsePrivateKeyPEMWithPassword(cakey, password)
 	if err != nil {
-		return nil, fmt.Errorf("Malformed private key %v", err)
+		return nil, fmt.Errorf("malformed private key %v", err)
 	}
 	return &cfsslSigner{
 		priv:                priv,
diff --git a/pkg/controller/cronjob/utils.go b/pkg/controller/cronjob/utils.go
@@ -94,7 +94,7 @@ func getRecentUnmetScheduleTimes(sj batchv1beta1.CronJob, now time.Time) ([]time
 	starts := []time.Time{}
 	sched, err := cron.ParseStandard(sj.Spec.Schedule)
 	if err != nil {
-		return starts, fmt.Errorf("Unparseable schedule: %s : %s", sj.Spec.Schedule, err)
+		return starts, fmt.Errorf("unparseable schedule: %s : %s", sj.Spec.Schedule, err)
 	}
 
 	var earliestTime time.Time
diff --git a/pkg/controller/daemon/update.go b/pkg/controller/daemon/update.go
@@ -49,7 +49,7 @@ func (dsc *DaemonSetsController) rollingUpdate(ds *apps.DaemonSet, nodeList []*v
 	_, oldPods := dsc.getAllDaemonSetPods(ds, nodeToDaemonPods, hash)
 	maxUnavailable, numUnavailable, err := dsc.getUnavailableNumbers(ds, nodeList, nodeToDaemonPods)
 	if err != nil {
-		return fmt.Errorf("Couldn't get unavailable numbers: %v", err)
+		return fmt.Errorf("couldn't get unavailable numbers: %v", err)
 	}
 	oldAvailablePods, oldUnavailablePods := util.SplitByAvailablePods(ds.Spec.MinReadySeconds, oldPods)
 
@@ -416,7 +416,7 @@ func (dsc *DaemonSetsController) getUnavailableNumbers(ds *apps.DaemonSet, nodeL
 	}
 	maxUnavailable, err := intstrutil.GetValueFromIntOrPercent(ds.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable, desiredNumberScheduled, true)
 	if err != nil {
-		return -1, -1, fmt.Errorf("Invalid value for MaxUnavailable: %v", err)
+		return -1, -1, fmt.Errorf("invalid value for MaxUnavailable: %v", err)
 	}
 	klog.V(4).Infof(" DaemonSet %s/%s, maxUnavailable: %d, numUnavailable: %d", ds.Namespace, ds.Name, maxUnavailable, numUnavailable)
 	return maxUnavailable, numUnavailable, nil
diff --git a/pkg/controller/garbagecollector/garbagecollector_test.go b/pkg/controller/garbagecollector/garbagecollector_test.go
@@ -857,7 +857,7 @@ func TestGarbageCollectorSync(t *testing.T) {
 
 	// Simulate the discovery client returning an error
 	fakeDiscoveryClient.setPreferredResources(nil)
-	fakeDiscoveryClient.setError(fmt.Errorf("Error calling discoveryClient.ServerPreferredResources()"))
+	fakeDiscoveryClient.setError(fmt.Errorf("error calling discoveryClient.ServerPreferredResources()"))
 
 	// Wait until sync discovers the change
 	time.Sleep(1 * time.Second)
diff --git a/pkg/controller/job/job_controller_test.go b/pkg/controller/job/job_controller_test.go
@@ -199,7 +199,7 @@ func TestControllerSyncJob(t *testing.T) {
 		},
 		"too few active pods, with controller error": {
 			2, 5, 6, false, 0,
-			fmt.Errorf("Fake error"), true, 0, 1, 1, 0,
+			fmt.Errorf("fake error"), true, 0, 1, 1, 0,
 			1, 0, 1, 1, 0, nil, "",
 		},
 		"too many active pods": {
@@ -209,17 +209,17 @@ func TestControllerSyncJob(t *testing.T) {
 		},
 		"too many active pods, with controller error": {
 			2, 5, 6, false, 0,
-			fmt.Errorf("Fake error"), true, 0, 3, 0, 0,
+			fmt.Errorf("fake error"), true, 0, 3, 0, 0,
 			0, 1, 3, 0, 0, nil, "",
 		},
 		"failed + succeed pods: reset backoff delay": {
 			2, 5, 6, false, 0,
-			fmt.Errorf("Fake error"), true, 0, 1, 1, 1,
+			fmt.Errorf("fake error"), true, 0, 1, 1, 1,
 			1, 0, 1, 1, 1, nil, "",
 		},
 		"only new failed pod": {
 			2, 5, 6, false, 0,
-			fmt.Errorf("Fake error"), false, 0, 1, 0, 1,
+			fmt.Errorf("fake error"), false, 0, 1, 0, 1,
 			1, 0, 1, 0, 1, nil, "",
 		},
 		"job finish": {
@@ -575,7 +575,7 @@ func TestSyncJobUpdateRequeue(t *testing.T) {
 	manager.podControl = &fakePodControl
 	manager.podStoreSynced = alwaysReady
 	manager.jobStoreSynced = alwaysReady
-	updateError := fmt.Errorf("Update error")
+	updateError := fmt.Errorf("update error")
 	manager.updateHandler = func(job *batch.Job) error {
 		manager.queue.AddRateLimited(testutil.GetKey(job, t))
 		return updateError
diff --git a/pkg/controller/nodeipam/ipam/cidr_allocator.go b/pkg/controller/nodeipam/ipam/cidr_allocator.go
@@ -101,7 +101,7 @@ func New(kubeClient clientset.Interface, cloud cloudprovider.Interface, nodeInfo
 	case CloudAllocatorType:
 		return NewCloudCIDRAllocator(kubeClient, cloud, nodeInformer)
 	default:
-		return nil, fmt.Errorf("Invalid CIDR allocator type: %v", allocatorType)
+		return nil, fmt.Errorf("invalid CIDR allocator type: %v", allocatorType)
 	}
 }
 
@@ -121,7 +121,7 @@ func listNodes(kubeClient clientset.Interface) (*v1.NodeList, error) {
 		}
 		return true, nil
 	}); pollErr != nil {
-		return nil, fmt.Errorf("Failed to list all nodes in %v, cannot proceed without updating CIDR map",
+		return nil, fmt.Errorf("failed to list all nodes in %v, cannot proceed without updating CIDR map",
 			apiserverStartupGracePeriod)
 	}
 	return nodeList, nil
diff --git a/pkg/controller/nodeipam/ipam/cidrset/cidr_set.go b/pkg/controller/nodeipam/ipam/cidrset/cidr_set.go
@@ -162,7 +162,7 @@ func (s *CidrSet) getBeginingAndEndIndices(cidr *net.IPNet) (begin, end int, err
 	var ipSize int
 
 	if cidr == nil {
-		return -1, -1, fmt.Errorf("Error getting indices for cluster cidr %v, cidr is nil", s.clusterCIDR)
+		return -1, -1, fmt.Errorf("error getting indices for cluster cidr %v, cidr is nil", s.clusterCIDR)
 	}
 
 	if !s.clusterCIDR.Contains(cidr.IP.Mask(s.clusterCIDR.Mask)) && !cidr.Contains(s.clusterCIDR.IP.Mask(cidr.Mask)) {
diff --git a/pkg/controller/nodeipam/ipam/range_allocator.go b/pkg/controller/nodeipam/ipam/range_allocator.go
diff --git a/pkg/controller/podautoscaler/horizontal.go b/pkg/controller/podautoscaler/horizontal.go
diff --git a/pkg/controller/replicaset/replica_set_test.go b/pkg/controller/replicaset/replica_set_test.go
diff --git a/pkg/controller/resourcequota/resource_quota_controller_test.go b/pkg/controller/resourcequota/resource_quota_controller_test.go
diff --git a/pkg/controller/service/service_controller_test.go b/pkg/controller/service/service_controller_test.go
diff --git a/pkg/controller/serviceaccount/tokens_controller_test.go b/pkg/controller/serviceaccount/tokens_controller_test.go
diff --git a/pkg/controller/statefulset/stateful_pod_control.go b/pkg/controller/statefulset/stateful_pod_control.go
diff --git a/pkg/controller/statefulset/stateful_pod_control_test.go b/pkg/controller/statefulset/stateful_pod_control_test.go
diff --git a/pkg/controller/statefulset/stateful_set_control_test.go b/pkg/controller/statefulset/stateful_set_control_test.go
diff --git a/pkg/controller/statefulset/stateful_set_status_updater_test.go b/pkg/controller/statefulset/stateful_set_status_updater_test.go
diff --git a/pkg/controller/testutil/test_utils.go b/pkg/controller/testutil/test_utils.go
diff --git a/pkg/controller/ttlafterfinished/ttlafterfinished_controller.go b/pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
diff --git a/pkg/controller/volume/attachdetach/cache/actual_state_of_world.go b/pkg/controller/volume/attachdetach/cache/actual_state_of_world.go

Original file line number	Diff line number	Diff line change
`@@ -79,14 +79,14 @@ func mountInChroot(rootfsPath string, args []string) error {`
`79`	`79`	`// Mount failed because it is NFS V3 and we need to run rpcBind`
`80`	`80`	`output, err = exec.Command(chrootCmd, rootfsPath, rpcBindCmd, "-w").CombinedOutput()`
`81`	`81`	`if err != nil {`
`82`		`- return fmt.Errorf("Mount issued for NFS V3 but unable to run rpcbind:\n Output: %s\n Error: %v", string(output), err)`
	`82`	`+ return fmt.Errorf("mount issued for NFS V3 but unable to run rpcbind:\n Output: %s\n Error: %v", string(output), err)`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`// Rpcbind is running, try mounting again`
`86`	`86`	`output, err = exec.Command(chrootCmd, args...).CombinedOutput()`
`87`	`87`
`88`	`88`	`if err != nil {`
`89`		`- return fmt.Errorf("Mount failed for NFS V3 even after running rpcBind %s, %v", string(output), err)`
	`89`	`+ return fmt.Errorf("mount failed for NFS V3 even after running rpcBind %s, %v", string(output), err)`
`90`	`90`	`}`
`91`	`91`
`92`	`92`	`return nil`
Original file line number	Diff line number	Diff line change
`@@ -195,12 +195,12 @@ func (e *CombinedEtcdClient) AttachLease(leaseDuration time.Duration) error {`
`195`	`195`	`defer v3client.Close()`
`196`	`196`	`objectsResp, err := v3client.KV.Get(ctx, ttlKeysPrefix, clientv3.WithPrefix())`
`197`	`197`	`if err != nil {`
`198`		`- return fmt.Errorf("Error while getting objects to attach to the lease")`
	`198`	`+ return fmt.Errorf("error while getting objects to attach to the lease")`
`199`	`199`	`}`
`200`	`200`
`201`	`201`	`lease, err := v3client.Lease.Grant(ctx, int64(leaseDuration/time.Second))`
`202`	`202`	`if err != nil {`
`203`		`- return fmt.Errorf("Error while creating lease: %v", err)`
	`203`	`+ return fmt.Errorf("error while creating lease: %v", err)`
`204`	`204`	`}`
`205`	`205`	`klog.Infof("Lease with TTL: %v created", lease.TTL)`
`206`	`206`
Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ func (r EtcdMigrateServer) Start(version EtcdVersion) error {`
`87`	`87`	`if err != nil {`
`88`	`88`	`return fmt.Errorf("error killing etcd: %v", err)`
`89`	`89`	`}`
`90`		`- return fmt.Errorf("Timed out waiting for etcd on port %d", r.cfg.port)`
	`90`	`+ return fmt.Errorf("timed out waiting for etcd on port %d", r.cfg.port)`
`91`	`91`	`}`
`92`	`92`	`}`
`93`	`93`	`}`
Original file line number	Diff line number	Diff line change
`@@ -111,7 +111,7 @@ type EtcdVersionPair struct {`
`111`	`111`	`func ParseEtcdVersionPair(s string) (*EtcdVersionPair, error) {`
`112`	`112`	`parts := strings.Split(s, "/")`
`113`	`113`	`if len(parts) != 2 {`
`114`		`- return nil, fmt.Errorf("Malformed version file, expected <major>.<minor>.<patch>/<storage> but got %s", s)`
	`114`	`+ return nil, fmt.Errorf("malformed version file, expected <major>.<minor>.<patch>/<storage> but got %s", s)`
`115`	`115`	`}`
`116`	`116`	`version, err := ParseEtcdVersion(parts[0])`
`117`	`117`	`if err != nil {`
Original file line number	Diff line number	Diff line change
`@@ -393,7 +393,7 @@ func TestConfigChange(t *testing.T) {`
`393`	`393`	`setUp := func() (*os.File, string, error) {`
`394`	`394`	`tempDir, err := ioutil.TempDir("", "kubeproxy-config-change")`
`395`	`395`	`if err != nil {`
`396`		`- return nil, "", fmt.Errorf("Unable to create temporary directory: %v", err)`
	`396`	`+ return nil, "", fmt.Errorf("unable to create temporary directory: %v", err)`
`397`	`397`	`}`
`398`	`398`	`fullPath := filepath.Join(tempDir, "kube-proxy-config")`
`399`	`399`	`file, err := os.Create(fullPath)`
Original file line number	Diff line number	Diff line change
`@@ -138,10 +138,10 @@ func newCmdKubeletConfigEnableDynamic() *cobra.Command {`
`138`	`138`	`Example: kubeletConfigEnableDynamicExample,`
`139`	`139`	`Run: func(cmd *cobra.Command, args []string) {`
`140`	`140`	`if len(nodeName) == 0 {`
`141`		`- kubeadmutil.CheckErr(errors.New("The --node-name argument is required"))`
	`141`	`+ kubeadmutil.CheckErr(errors.New("the --node-name argument is required"))`
`142`	`142`	`}`
`143`	`143`	`if len(kubeletVersionStr) == 0 {`
`144`		`- kubeadmutil.CheckErr(errors.New("The --kubelet-version argument is required"))`
	`144`	`+ kubeadmutil.CheckErr(errors.New("the --kubelet-version argument is required"))`
`145`	`145`	`}`
`146`	`146`
`147`	`147`	`kubeletVersion, err := version.ParseSemantic(kubeletVersionStr)`
Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,7 @@ func runPreflight(c workflow.RunData) error {`
`58`	`58`	`return err`
`59`	`59`	`}`
`60`	`60`	`if strings.ToLower(s.Text()) != "y" {`
`61`		`- return errors.New("Aborted reset operation")`
	`61`	`+ return errors.New("aborted reset operation")`
`62`	`62`	`}`
`63`	`63`	`}`
`64`	`64`
Original file line number	Diff line number	Diff line change
`@@ -428,7 +428,7 @@ func EtcdSupportedVersion(versionString string) (*version.Version, error) {`
`428`	`428`	`}`
`429`	`429`	`return etcdVersion, nil`
`430`	`430`	`}`
`431`		`- return nil, errors.Errorf("Unsupported or unknown Kubernetes version(%v)", kubernetesVersion)`
	`431`	`+ return nil, errors.Errorf("unsupported or unknown Kubernetes version(%v)", kubernetesVersion)`
`432`	`432`	`}`
`433`	`433`
`434`	`434`	`// GetStaticPodDirectory returns the location on the disk where the Static Pod should be present`
Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ func TestEtcdSupportedVersion(t *testing.T) {`
`157`	`157`	`{`
`158`	`158`	`kubernetesVersion: "1.99.0",`
`159`	`159`	`expectedVersion: nil,`
`160`		`- expectedError: errors.New("Unsupported or unknown Kubernetes version(1.99.0)"),`
	`160`	`+ expectedError: errors.New("unsupported or unknown Kubernetes version(1.99.0)"),`
`161`	`161`	`},`
`162`	`162`	`{`
`163`	`163`	`kubernetesVersion: MinimumControlPlaneVersion.WithPatch(1).String(),`