Error string shouldn't be capitalized

Author: ChunyiLyu

controllers/reconcile_persistence.go

@@ -18,7 +18,7 @@ func (r *RabbitmqClusterReconciler) reconcilePVC(ctx context.Context, rmq *rabbi
 	err := scaling.NewPersistenceScaler(r.Clientset).Scale(ctx, *rmq, desiredCapacity)
 	if err != nil {
 		msg := fmt.Sprintf("Failed to scale PVCs: %s", err.Error())
-		logger.Error(fmt.Errorf("Hit an error while scaling PVC capacity: %w", err), msg)
+		logger.Error(fmt.Errorf("hit an error while scaling PVC capacity: %w", err), msg)
 		r.Recorder.Event(rmq, corev1.EventTypeWarning, "FailedReconcilePersistence", msg)
 	}
 	return err

internal/metadata/annotation_test.go

@@ -3,7 +3,7 @@ package metadata_test
 import (
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
-	internal_metadata "github.com/rabbitmq/cluster-operator/internal/metadata"
+	internalmetadata "github.com/rabbitmq/cluster-operator/internal/metadata"
 )
 
 var _ = Describe("Annotation", func() {
@@ -16,7 +16,7 @@ var _ = Describe("Annotation", func() {
 
 	DescribeTable("Reconcile annotations",
 		func(expectedAnnotations map[string]string, existingAnnotations map[string]string, defaultAnnotations ...map[string]string) {
-			reconciledAnnotations := internal_metadata.ReconcileAnnotations(existingAnnotations, defaultAnnotations...)
+			reconciledAnnotations := internalmetadata.ReconcileAnnotations(existingAnnotations, defaultAnnotations...)
 			Expect(reconciledAnnotations).To(Equal(expectedAnnotations))
 		},
 
@@ -55,7 +55,7 @@ var _ = Describe("Annotation", func() {
 
 	DescribeTable("Reconcile and filter annotations",
 		func(expectedAnnotations map[string]string, existingAnnotations map[string]string, defaultAnnotations ...map[string]string) {
-			reconciledAnnotations := internal_metadata.ReconcileAndFilterAnnotations(existingAnnotations, defaultAnnotations...)
+			reconciledAnnotations := internalmetadata.ReconcileAndFilterAnnotations(existingAnnotations, defaultAnnotations...)
 			Expect(reconciledAnnotations).To(Equal(expectedAnnotations))
 		},
 

internal/scaling/scaling.go

@@ -34,7 +34,7 @@ func (p PersistenceScaler) Scale(ctx context.Context, rmq rabbitmqv1beta1.Rabbit
 
 	existingCapacity, err := p.existingCapacity(ctx, rmq)
 	if client.IgnoreNotFound(err) != nil {
-		logErr := fmt.Errorf("Failed to determine existing STS capactiy: %w", err)
+		logErr := fmt.Errorf("failed to determine existing STS capactiy: %w", err)
 		logger.Error(logErr, "Could not read sts")
 		return logErr
 	}
@@ -65,7 +65,7 @@ func (p PersistenceScaler) Scale(ctx context.Context, rmq rabbitmqv1beta1.Rabbit
 	logger.Info("Scaling up PVCs", "RabbitmqCluster", rmq.Name, "pvcsToBeScaled", pvcsToBeScaled)
 
 	if err := p.deleteSts(ctx, rmq); err != nil {
-		logErr := fmt.Errorf("Failed to delete Statefulset from Kubernetes API: %w", err)
+		logErr := fmt.Errorf("failed to delete Statefulset from Kubernetes API: %w", err)
 		logger.Error(logErr, "Could not delete existing sts")
 		return logErr
 	}
@@ -82,7 +82,7 @@ func (p PersistenceScaler) getClusterPVCs(ctx context.Context, rmq rabbitmqv1bet
 	for i = 0; i < pointer.Int32Deref(rmq.Spec.Replicas, 1); i++ {
 		pvc, err := p.Client.CoreV1().PersistentVolumeClaims(rmq.Namespace).Get(ctx, rmq.PVCName(int(i)), metav1.GetOptions{})
 		if client.IgnoreNotFound(err) != nil {
-			logErr := fmt.Errorf("Failed to get PVC from Kubernetes API: %w", err)
+			logErr := fmt.Errorf("failed to get PVC from Kubernetes API: %w", err)
 			logger.Error(logErr, "Could not read existing PVC")
 			return nil, logErr
 		}
@@ -137,7 +137,7 @@ func (p PersistenceScaler) deleteSts(ctx context.Context, rmq rabbitmqv1beta1.Ra
 
 	sts, err := p.getSts(ctx, rmq)
 	if client.IgnoreNotFound(err) != nil {
-		logErr := fmt.Errorf("Failed to get statefulset from Kubernetes API: %w", err)
+		logErr := fmt.Errorf("failed to get statefulset from Kubernetes API: %w", err)
 		logger.Error(logErr, "Could not read existing statefulset")
 		return logErr
 	}
@@ -174,7 +174,7 @@ func (p PersistenceScaler) scaleUpPVCs(ctx context.Context, rmq rabbitmqv1beta1.
 		// To minimise any timing windows, retrieve the latest version of this PVC before updating
 		pvc, err := p.Client.CoreV1().PersistentVolumeClaims(pvc.Namespace).Get(ctx, pvc.Name, metav1.GetOptions{})
 		if err != nil {
-			logErr := fmt.Errorf("Failed to get PVC from Kubernetes API: %w", err)
+			logErr := fmt.Errorf("failed to get PVC from Kubernetes API: %w", err)
 			logger.Error(logErr, "Could not read existing PVC")
 			return logErr
 		}

internal/scaling/scaling_suite_test.go

@@ -201,7 +201,7 @@ func (matcher *UpdateActionMatcher) Match(actual interface{}) (bool, error) {
 	updatedObject := reflect.ValueOf(action.GetObject()).Elem()
 	objMeta, ok := updatedObject.FieldByName("ObjectMeta").Interface().(metav1.ObjectMeta)
 	if !ok {
-		return false, fmt.Errorf("Object of action was not an object with ObjectMeta")
+		return false, fmt.Errorf("object of action was not an object with ObjectMeta")
 	}
 
 	// Check the object's Name, Namespace, resource type and the verb of the action first. If this fails, there's