Set integration test to run in parallel

server/backend/database/testcases/testcases.go

@@ -47,7 +47,7 @@ const (
 )
 
 // RunFindDocInfoTest runs the FindDocInfo test for the given db.
-// TODO(binary-ho) : temporary comment for measure CI test time
+// TODO(binary-ho): temporary comment for measure CI test time
 func RunFindDocInfoTest(
 	t *testing.T,
 	db database.Database,

test/integration/admin_test.go

@@ -36,6 +36,8 @@ import (
 )
 
 func TestAdmin(t *testing.T) {
+	t.Parallel()
+
 	ctx := context.Background()
 
 	adminCli, err := admin.Dial(defaultServer.RPCAddr(), admin.WithInsecure(true))

test/integration/array_test.go

@@ -34,6 +34,8 @@ import (
 )
 
 func TestArray(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)
@@ -328,6 +330,8 @@ func TestArray(t *testing.T) {
 }
 
 func TestArraySetTypeGuard(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 1)
 	c1 := clients[0]
 	defer deactivateAndCloseClients(t, clients)
@@ -385,6 +389,8 @@ func TestArraySetTypeGuard(t *testing.T) {
 }
 
 func TestArraySet(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 1)
 	c1 := clients[0]
 	defer deactivateAndCloseClients(t, clients)

test/integration/client_test.go

@@ -37,6 +37,7 @@ import (
 
 func TestClient(t *testing.T) {
 	t.Run("dial and close test", func(t *testing.T) {
+		t.Parallel()
 		cli, err := client.Dial(defaultServer.RPCAddr())
 		assert.NoError(t, err)
 
@@ -47,6 +48,7 @@ func TestClient(t *testing.T) {
 	})
 
 	t.Run("activate/deactivate test", func(t *testing.T) {
+		t.Parallel()
 		cli, err := client.Dial(defaultServer.RPCAddr())
 		assert.NoError(t, err)
 		defer func() {
@@ -76,6 +78,7 @@ func TestClient(t *testing.T) {
 	})
 
 	t.Run("sync option with multiple clients test", func(t *testing.T) {
+		t.Parallel()
 		clients := activeClients(t, 3)
 		defer deactivateAndCloseClients(t, clients)
 		c1, c2, c3 := clients[0], clients[1], clients[2]
@@ -131,6 +134,7 @@ func TestClient(t *testing.T) {
 	})
 
 	t.Run("sync option with mixed mode test", func(t *testing.T) {
+		t.Parallel()
 		clients := activeClients(t, 1)
 		defer deactivateAndCloseClients(t, clients)
 		cli := clients[0]
@@ -176,6 +180,7 @@ func TestClient(t *testing.T) {
 	})
 
 	t.Run("deactivated client's stream test", func(t *testing.T) {
+		t.Parallel()
 		ctx := context.Background()
 
 		c1, err := client.Dial(defaultServer.RPCAddr())

test/integration/counter_test.go

@@ -33,6 +33,8 @@ import (
 )
 
 func TestCounter(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)

test/integration/document_test.go

@@ -39,6 +39,8 @@ import (
 )
 
 func TestDocument(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 3)
 	c1, c2, c3 := clients[0], clients[1], clients[2]
 	defer deactivateAndCloseClients(t, clients)
@@ -689,6 +691,8 @@ func TestDocument(t *testing.T) {
 }
 
 func TestDocumentWithProjects(t *testing.T) {
+	t.Parallel()
+
 	ctx := context.Background()
 	adminCli := helper.CreateAdminCli(t, defaultServer.RPCAddr())
 	defer func() { adminCli.Close() }()

test/integration/gc_test.go

@@ -35,6 +35,8 @@ import (
 )
 
 func TestGarbageCollection(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)

test/integration/health_test.go

@@ -40,6 +40,8 @@ var services = []string{
 }
 
 func TestRPCHealthCheck(t *testing.T) {
+	t.Parallel()
+
 	conn, err := grpc.Dial(
 		defaultServer.RPCAddr(),
 		grpc.WithTransportCredentials(insecure.NewCredentials()),
@@ -79,6 +81,8 @@ func TestRPCHealthCheck(t *testing.T) {
 }
 
 func TestHTTPGETHealthCheck(t *testing.T) {
+	t.Parallel()
+
 	// check default service
 	t.Run("Service: default", func(t *testing.T) {
 		resp, err := http.Get("http://" + defaultServer.RPCAddr() + httphealth.HealthV1ServiceName)
@@ -125,6 +129,8 @@ func TestHTTPGETHealthCheck(t *testing.T) {
 }
 
 func TestHTTPHEADHealthCheck(t *testing.T) {
+	t.Parallel()
+
 	// check default service
 	t.Run("Service: default", func(t *testing.T) {
 		resp, err := http.Head("http://" + defaultServer.RPCAddr() + httphealth.HealthV1ServiceName)

test/integration/history_test.go

@@ -31,6 +31,8 @@ import (
 )
 
 func TestHistory(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 1)
 	cli := clients[0]
 	defer deactivateAndCloseClients(t, clients)

test/integration/housekeeping_test.go

@@ -70,6 +70,8 @@ func setupBackend(t *testing.T) *backend.Backend {
 }
 
 func TestHousekeeping(t *testing.T) {
+	t.Parallel()
+
 	be := setupBackend(t)
 	defer func() {
 		assert.NoError(t, be.Shutdown())

test/integration/object_test.go

@@ -34,6 +34,8 @@ import (
 )
 
 func TestObject(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)
@@ -359,6 +361,8 @@ func TestObject(t *testing.T) {
 }
 
 func TestObjectTypeGuard(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 1)
 	c1 := clients[0]
 	defer deactivateAndCloseClients(t, clients)
@@ -419,6 +423,8 @@ func TestObjectTypeGuard(t *testing.T) {
 }
 
 func TestObjectSetCycle(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 1)
 	c1 := clients[0]
 	defer deactivateAndCloseClients(t, clients)
@@ -481,6 +487,8 @@ func TestObjectSetCycle(t *testing.T) {
 }
 
 func TestObjectSet(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 1)
 	c1 := clients[0]
 	defer deactivateAndCloseClients(t, clients)

test/integration/presence_test.go

@@ -38,6 +38,8 @@ import (
 )
 
 func TestPresence(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)

test/integration/primitive_test.go

@@ -32,6 +32,8 @@ import (
 )
 
 func TestPrimitive(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)

test/integration/restapi_test.go

@@ -44,6 +44,7 @@ type documentSummary struct {
 
 func TestRESTAPI(t *testing.T) {
 	t.Run("document retrieval test", func(t *testing.T) {
+		t.Parallel()
 		project, docs := helper.CreateProjectAndDocuments(t, defaultServer, 3)
 		res := post(
 			t,
@@ -58,6 +59,7 @@ func TestRESTAPI(t *testing.T) {
 	})
 
 	t.Run("bulk document retrieval test", func(t *testing.T) {
+		t.Parallel()
 		project, docs := helper.CreateProjectAndDocuments(t, defaultServer, 3)
 		res := post(
 			t,
@@ -72,6 +74,7 @@ func TestRESTAPI(t *testing.T) {
 	})
 
 	t.Run("list documents test", func(t *testing.T) {
+		t.Parallel()
 		project, _ := helper.CreateProjectAndDocuments(t, defaultServer, 3)
 		res := post(
 			t,
@@ -86,6 +89,7 @@ func TestRESTAPI(t *testing.T) {
 	})
 
 	t.Run("search documents test", func(t *testing.T) {
+		t.Parallel()
 		project, docs := helper.CreateProjectAndDocuments(t, defaultServer, 3)
 		res := post(
 			t,

test/integration/retention_test.go

@@ -40,6 +40,8 @@ import (
 )
 
 func TestRetention(t *testing.T) {
+	t.Parallel()
+
 	var b *background.Background
 	patch, err := monkey.PatchInstanceMethodByName(
 		reflect.TypeOf(b),

test/integration/server_test.go

@@ -33,6 +33,7 @@ import (
 
 func TestServer(t *testing.T) {
 	t.Run("closing WatchDocument stream on server shutdown test", func(t *testing.T) {
+		t.Parallel()
 		ctx := context.Background()
 		svr := helper.TestServer()
 		assert.NoError(t, svr.Start())

test/integration/snapshot_test.go

@@ -36,6 +36,8 @@ import (
 )
 
 func TestSnapshot(t *testing.T) {
+	t.Parallel()
+
 	var b *background.Background
 	patch, err := monkey.PatchInstanceMethodByName(
 		reflect.TypeOf(b),

test/integration/text_test.go

@@ -31,6 +31,8 @@ import (
 )
 
 func TestText(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)

test/integration/tree_concurrency_test.go

@@ -261,6 +261,8 @@ func TestTreeConcurrencyEditEdit(t *testing.T) {
 	//       0   1 2 3 4    5   6 7 8 9    10   11 12 13 14    15
 	// <root> <p> a b c </p> <p> d e f </p>  <p>  g  h  i  </p>  </root>
 
+	t.Parallel()
+
 	initialState := json.TreeNode{
 		Type: "root",
 		Children: []json.TreeNode{
@@ -330,6 +332,8 @@ func TestTreeConcurrencySplitSplit(t *testing.T) {
 	//       0   1   2   3   4 5 6 7 8    9   10 11 12 13 14    15    16   17 18 19 20 21    22    23    24
 	// <root> <p> <p> <p> <p> a b c d </p> <p>  e  f  g  h  </p>  </p>  <p>  i  j  k  l  </p>  </p>  </p>  </root>
 
+	t.Parallel()
+
 	initialState := json.TreeNode{
 		Type: "root",
 		Children: []json.TreeNode{
@@ -377,6 +381,8 @@ func TestTreeConcurrencySplitEdit(t *testing.T) {
 	//       0   1   2   3 4 5 6 7    8   9 10 11 12 13    14    15   16 17 18 19 20    21    22
 	// <root> <p> <p> <p> a b c d </p> <p> e  f  g  h  </p>  </p>  <p>  i  j  k  l  </p>  </p>  </root>
 
+	t.Parallel()
+
 	initialState := json.TreeNode{
 		Type: "root",
 		Children: []json.TreeNode{
@@ -440,6 +446,8 @@ func TestTreeConcurrencyStyleStyle(t *testing.T) {
 	// 3,6 :            |----------|
 	// 6,9 :                       |----------|
 
+	t.Parallel()
+
 	initialState := json.TreeNode{
 		Type: "root",
 		Children: []json.TreeNode{
@@ -480,6 +488,8 @@ func TestTreeConcurrencyEditStyle(t *testing.T) {
 	// 3,6 :            |----------|
 	// 6,9 :                       |----------|
 
+	t.Parallel()
+
 	initialState := json.TreeNode{
 		Type: "root",
 		Children: []json.TreeNode{

test/integration/tree_test.go

@@ -34,6 +34,8 @@ import (
 )
 
 func TestTree(t *testing.T) {
+	t.Parallel()
+
 	clients := activeClients(t, 2)
 	c1, c2 := clients[0], clients[1]
 	defer deactivateAndCloseClients(t, clients)

test/integration/user_test.go

@@ -29,6 +29,8 @@ import (
 )
 
 func TestUser(t *testing.T) {
+	t.Parallel()
+
 	adminCli := helper.CreateAdminCli(t, defaultServer.RPCAddr())
 	defer func() { adminCli.Close() }()