speedup tests

Author: roblaszczak

sns/pubsub_test.go

@@ -23,6 +23,8 @@ import (
 )
 
 func TestPublishSubscribe(t *testing.T) {
+	t.Parallel()
+
 	tests.TestPubSub(
 		t,
 		tests.Features{
@@ -37,6 +39,8 @@ func TestPublishSubscribe(t *testing.T) {
 }
 
 func TestPubSub_arn_topic_resolver(t *testing.T) {
+	t.Parallel()
+
 	tests.TestPublishSubscribe(
 		t,
 		tests.TestContext{
@@ -90,6 +94,8 @@ func TestPubSub_arn_topic_resolver(t *testing.T) {
 }
 
 func TestPublisher_CreateTopic_is_idempotent(t *testing.T) {
+	t.Parallel()
+
 	pub, _ := createPubSub(t)
 
 	topicName := watermill.NewUUID()
@@ -104,6 +110,8 @@ func TestPublisher_CreateTopic_is_idempotent(t *testing.T) {
 }
 
 func TestSubscriber_SubscribeInitialize_is_idempotent(t *testing.T) {
+	t.Parallel()
+
 	_, sub := createPubSub(t)
 
 	topicName := watermill.NewUUID()

sqs/pubsub_stress_test.go

@@ -0,0 +1,18 @@
+//go:build stress
+// +build stress
+
+package sqs
+
+func TestPubSub_stress(t *testing.T) {
+	tests.TestPubSubStressTest(
+		t,
+		tests.Features{
+			ConsumerGroups:      false,
+			ExactlyOnceDelivery: false,
+			GuaranteedOrder:     true,
+			Persistent:          true,
+		},
+		createPubSub,
+		createPubSubWithConsumerGroup,
+	)
+}

sqs/pubsub_test.go

@@ -21,21 +21,9 @@ import (
 )
 
 func TestPubSub(t *testing.T) {
-	tests.TestPubSub(
-		t,
-		tests.Features{
-			ConsumerGroups:      false,
-			ExactlyOnceDelivery: false,
-			GuaranteedOrder:     true,
-			Persistent:          true,
-		},
-		createPubSub,
-		createPubSubWithConsumerGroup,
-	)
-}
+	t.Parallel()
 
-func TestPubSub_stress(t *testing.T) {
-	tests.TestPubSubStressTest(
+	tests.TestPubSub(
 		t,
 		tests.Features{
 			ConsumerGroups:      false,
@@ -49,6 +37,8 @@ func TestPubSub_stress(t *testing.T) {
 }
 
 func TestPublishSubscribe_with_GenerateQueueUrlResolver(t *testing.T) {
+	t.Parallel()
+
 	tests.TestPublishSubscribe(
 		t,
 		tests.TestContext{
@@ -112,6 +102,8 @@ func TestPublishSubscribe_with_GenerateQueueUrlResolver(t *testing.T) {
 }
 
 func TestPublishSubscribe_with_TransparentUrlResolver(t *testing.T) {
+	t.Parallel()
+
 	tests.TestPublishSubscribe(
 		t,
 		tests.TestContext{
@@ -175,6 +167,8 @@ func TestPublishSubscribe_with_TransparentUrlResolver(t *testing.T) {
 }
 
 func TestPublishSubscribe_batching(t *testing.T) {
+	t.Parallel()
+
 	tests.TestPublishSubscribe(
 		t,
 		tests.TestContext{
@@ -231,6 +225,8 @@ func TestPublishSubscribe_batching(t *testing.T) {
 }
 
 func TestPublishSubscribe_creating_queue_with_different_settings_should_be_idempotent(t *testing.T) {
+	t.Parallel()
+
 	logger := watermill.NewStdLogger(false, false)
 
 	sub1, err := sqs.NewSubscriber(sqs.SubscriberConfig{
@@ -264,6 +260,8 @@ func TestPublishSubscribe_creating_queue_with_different_settings_should_be_idemp
 }
 
 func TestPublisher_GetOrCreateQueueUrl_is_idempotent(t *testing.T) {
+	t.Parallel()
+
 	pub, _ := createPubSub(t)
 
 	topicName := watermill.NewUUID()
@@ -280,6 +278,8 @@ func TestPublisher_GetOrCreateQueueUrl_is_idempotent(t *testing.T) {
 }
 
 func TestSubscriber_doesnt_hang_when_queue_doesnt_exist(t *testing.T) {
+	t.Parallel()
+
 	cfg := newAwsConfig(t)
 
 	_, sub := createPubSubWithConfig(
@@ -315,6 +315,8 @@ func TestSubscriber_doesnt_hang_when_queue_doesnt_exist(t *testing.T) {
 }
 
 func TestPublisher_do_not_create_queue(t *testing.T) {
+	t.Parallel()
+
 	cfg := newAwsConfig(t)
 
 	pub, _ := createPubSubWithConfig(