add t.Parallel

Author: Furkhat Kasymov Genii Uulu

internal/actions/csr/integration_test.go

@@ -29,6 +29,7 @@ import (
 )
 
 func TestIntegration(t *testing.T) {
+	t.Parallel()
 	testIntegration(t, certv1.SchemeGroupVersion)
 	testIntegration(t, certv1beta1.SchemeGroupVersion)
 }

internal/castai/client_test.go

@@ -7,6 +7,7 @@ import (
 )
 
 func TestNewRestryClient_TLS(t *testing.T) {
+	t.Parallel()
 	t.Run("should populate tls.Config RootCAs when valid certificate presented", func(t *testing.T) {
 		r := require.New(t)
 

internal/config/config_test.go

@@ -11,6 +11,7 @@ import (
 )
 
 func TestConfig(t *testing.T) {
+	t.Parallel()
 	clusterId := uuid.New().String()
 	require.NoError(t, os.Setenv("API_KEY", "abc"))
 	require.NoError(t, os.Setenv("API_URL", "api.cast.ai"))

internal/config/retry_test.go

@@ -13,6 +13,7 @@ import (
 )
 
 func TestKubeRetryTransport(t *testing.T) {
+	t.Parallel()
 	log := logrus.New()
 	log.SetLevel(logrus.DebugLevel)
 

internal/helm/chart_loader_test.go

@@ -12,6 +12,7 @@ import (
 )
 
 func TestIntegration_ChartLoader(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
 	defer cancel()

internal/helm/client_test.go

@@ -20,6 +20,7 @@ import (
 )
 
 func TestClientInstall(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 
 	client := &client{
@@ -47,6 +48,7 @@ func TestClientInstall(t *testing.T) {
 }
 
 func TestClientUpdate(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 
 	currentRelease := buildNginxIngressRelease(release.StatusDeployed)
@@ -76,6 +78,7 @@ func TestClientUpdate(t *testing.T) {
 }
 
 func TestClientUpdateResetThenReuseValue(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 
 	currentRelease := buildNginxIngressRelease(release.StatusDeployed)
@@ -106,6 +109,7 @@ func TestClientUpdateResetThenReuseValue(t *testing.T) {
 }
 
 func TestClientUninstall(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 
 	currentRelease := buildNginxIngressRelease(release.StatusDeployed)

internal/k8sversion/version_test.go

@@ -13,6 +13,7 @@ import (
 )
 
 func Test(t *testing.T) {
+	t.Parallel()
 	v := version.Info{
 		Major:     "1",
 		Minor:     "21+",

internal/monitor/metatada_test.go

@@ -14,6 +14,7 @@ import (
 )
 
 func TestSaveMetadata(t *testing.T) {
+	t.Parallel()
 	tests := map[string]struct {
 		createDir     string
 		file          string
@@ -61,6 +62,7 @@ func TestSaveMetadata(t *testing.T) {
 }
 
 func Test_monitor_waitForMetadata(t *testing.T) {
+	t.Parallel()
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
 	defer cancel()
 

internal/waitext/extensions_test.go

@@ -12,6 +12,7 @@ import (
 )
 
 func TestNewConstantBackoff(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 	expectedSleepDuration := 10 * time.Second
 	backoff := NewConstantBackoff(expectedSleepDuration)
@@ -22,6 +23,7 @@ func TestNewConstantBackoff(t *testing.T) {
 }
 
 func TestDefaultExponentialBackoff(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 
 	val := DefaultExponentialBackoff()
@@ -33,10 +35,13 @@ func TestDefaultExponentialBackoff(t *testing.T) {
 }
 
 func TestRetry(t *testing.T) {
+	t.Parallel()
 	r := require.New(t)
 
 	t.Run("Retrying logic tests", func(t *testing.T) {
+		t.Parallel()
 		t.Run("Called at least once, even if retries or steps is 0", func(t *testing.T) {
+			t.Parallel()
 			called := false
 			err := Retry(context.Background(), wait.Backoff{Steps: 0}, 0, func(_ context.Context) (bool, error) {
 				called = true
@@ -48,6 +53,7 @@ func TestRetry(t *testing.T) {
 		})
 
 		t.Run("Respects backoff and retry count", func(t *testing.T) {
+			t.Parallel()
 			retries := 4
 			expectedTotalExecutions := 1 + retries
 			backoff := DefaultExponentialBackoff()
@@ -88,6 +94,7 @@ func TestRetry(t *testing.T) {
 		})
 
 		t.Run("Returns last encountered error", func(t *testing.T) {
+			t.Parallel()
 			timesCalled := 0
 			expectedErrMessage := "boom 3"
 
@@ -101,6 +108,7 @@ func TestRetry(t *testing.T) {
 		})
 
 		t.Run("Does not retry if false is returned as first parameter", func(t *testing.T) {
+			t.Parallel()
 			expectedErr := errors.New("dummy")
 			called := false
 			err := Retry(context.Background(), NewConstantBackoff(10*time.Millisecond), 10,
@@ -115,7 +123,9 @@ func TestRetry(t *testing.T) {
 	})
 
 	t.Run("Notify callback tests", func(t *testing.T) {
+		t.Parallel()
 		t.Run("Notify is passed and called", func(t *testing.T) {
+			t.Parallel()
 			err := Retry(
 				context.Background(),
 				NewConstantBackoff(10*time.Millisecond),
@@ -131,6 +141,7 @@ func TestRetry(t *testing.T) {
 		})
 
 		t.Run("Notify is not passed, no panic", func(t *testing.T) {
+			t.Parallel()
 			err := Retry(
 				context.Background(),
 				NewConstantBackoff(10*time.Millisecond),
@@ -145,7 +156,9 @@ func TestRetry(t *testing.T) {
 	})
 
 	t.Run("Context tests", func(t *testing.T) {
+		t.Parallel()
 		t.Run("On context cancel, stops", func(t *testing.T) {
+			t.Parallel()
 			ctx, cancel := context.WithCancelCause(context.Background())
 
 			innerError := errors.New("from operation")
@@ -168,6 +181,7 @@ func TestRetry(t *testing.T) {
 		})
 
 		t.Run("Operation is called at least once, even if context is cancelled", func(t *testing.T) {
+			t.Parallel()
 			ctx, cancel := context.WithCancel(context.Background())
 			cancel()