test(deisctl): parallelize all of the things

Joshua Anderson · Joshua Anderson · commit 8c0e11245434 · 2015-06-19T09:11:00.000-07:00
diff --git a/deisctl/backend/fleet/create_test.go b/deisctl/backend/fleet/create_test.go
@@ -11,6 +11,7 @@ import (
 )
 
 func TestCreate(t *testing.T) {
+	t.Parallel()
 
 	unitFiles := []string{"deis-controller.service", "deis-builder.service",
 		"deis-router.service"}
diff --git a/deisctl/backend/fleet/destroy_test.go b/deisctl/backend/fleet/destroy_test.go
@@ -9,6 +9,8 @@ import (
 )
 
 func TestDestroy(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name: "deis-registry.service",
diff --git a/deisctl/backend/fleet/fleet_test.go b/deisctl/backend/fleet/fleet_test.go
@@ -127,6 +127,8 @@ func logState(outchan chan string, errchan chan error, errOutput *string, mutex
 }
 
 func TestNewClient(t *testing.T) {
+	t.Parallel()
+
 	// set required flags
 	Flags.Endpoint = "http://127.0.0.1:4001"
 
diff --git a/deisctl/backend/fleet/journal_test.go b/deisctl/backend/fleet/journal_test.go
@@ -34,6 +34,8 @@ func (m mockJournalCommandRunner) RemoteCommand(cmd string, addr string, timeout
 }
 
 func TestJournal(t *testing.T) {
+	t.Parallel()
+
 	testMachines := []machine.MachineState{
 		machine.MachineState{
 			ID:       "test-1",
diff --git a/deisctl/backend/fleet/list_unit_files_test.go b/deisctl/backend/fleet/list_unit_files_test.go
@@ -12,6 +12,7 @@ import (
 )
 
 func TestListUnitFiles(t *testing.T) {
+	t.Parallel()
 
 	testUnits := []*schema.Unit{
 		&schema.Unit{
diff --git a/deisctl/backend/fleet/list_units_test.go b/deisctl/backend/fleet/list_units_test.go
@@ -12,6 +12,7 @@ import (
 )
 
 func TestListUnits(t *testing.T) {
+	t.Parallel()
 
 	testUnitStates := []*schema.UnitState{
 		&schema.UnitState{
diff --git a/deisctl/backend/fleet/registry_test.go b/deisctl/backend/fleet/registry_test.go
@@ -6,6 +6,8 @@ import (
 )
 
 func TestGetTunnelFlag(t *testing.T) {
+	t.Parallel()
+
 	flag := getTunnelFlag()
 	if flag != "" {
 		t.Fatalf("got %v, expected \"\"", flag)
@@ -23,6 +25,8 @@ func TestGetTunnelFlag(t *testing.T) {
 }
 
 func TestGetChecker(t *testing.T) {
+	t.Parallel()
+
 	Flags.StrictHostKeyChecking = false
 	checker := getChecker()
 	if checker != nil {
@@ -31,13 +35,17 @@ func TestGetChecker(t *testing.T) {
 }
 
 func TestFakeClient(t *testing.T) {
+	t.Parallel()
+
 	_, err := getFakeClient()
 	if err != nil {
 		t.Fatal(err)
 	}
 }
 
 func TestRegistryClient(t *testing.T) {
+	t.Parallel()
+
 	Flags.Tunnel = ""
 	Flags.Endpoint = "http://127.0.0.1:4001"
 	_, err := getRegistryClient()
diff --git a/deisctl/backend/fleet/scale_test.go b/deisctl/backend/fleet/scale_test.go
@@ -11,6 +11,8 @@ import (
 )
 
 func TestScaleUp(t *testing.T) {
+	t.Parallel()
+
 	name, err := ioutil.TempDir("", "deisctl-fleetctl")
 
 	if err != nil {
@@ -71,6 +73,8 @@ func TestScaleUp(t *testing.T) {
 }
 
 func TestScaleDown(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name:         "deis-router@1.service",
@@ -130,6 +134,8 @@ func TestScaleDown(t *testing.T) {
 }
 
 func TestScaleError(t *testing.T) {
+	t.Parallel()
+
 	c := &FleetClient{Fleet: &stubFleetClient{}}
 
 	var errOutput string
diff --git a/deisctl/backend/fleet/ssh_test.go b/deisctl/backend/fleet/ssh_test.go
@@ -26,6 +26,8 @@ func (mockCommandRunner) RemoteCommand(cmd string, addr string, timeout time.Dur
 }
 
 func TestRunCommand(t *testing.T) {
+	t.Parallel()
+
 	expected := machine.MachineState{
 		ID:       "test-1",
 		PublicIP: "1.1.1.1",
@@ -51,6 +53,8 @@ func TestRunCommand(t *testing.T) {
 }
 
 func TestFindUnit(t *testing.T) {
+	t.Parallel()
+
 	expectedID := "testing"
 
 	testUnits := []*schema.Unit{
@@ -97,6 +101,8 @@ func TestFindUnit(t *testing.T) {
 }
 
 func TestMachineState(t *testing.T) {
+	t.Parallel()
+
 	expected := machine.MachineState{
 		ID:       "test-1",
 		PublicIP: "1.1.1.1",
diff --git a/deisctl/backend/fleet/start_test.go b/deisctl/backend/fleet/start_test.go
@@ -9,6 +9,8 @@ import (
 )
 
 func TestStart(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name:         "deis-controller.service",
diff --git a/deisctl/backend/fleet/status_test.go b/deisctl/backend/fleet/status_test.go
@@ -34,6 +34,8 @@ func (m mockStatusCommandRunner) RemoteCommand(cmd string, addr string, timeout
 }
 
 func TestStatus(t *testing.T) {
+	t.Parallel()
+
 	testMachines := []machine.MachineState{
 		machine.MachineState{
 			ID:       "test-1",
diff --git a/deisctl/backend/fleet/stop_test.go b/deisctl/backend/fleet/stop_test.go
@@ -9,6 +9,8 @@ import (
 )
 
 func TestStop(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name:         "deis-controller.service",
diff --git a/deisctl/backend/fleet/unit_test.go b/deisctl/backend/fleet/unit_test.go
@@ -13,6 +13,8 @@ import (
 )
 
 func TestUnits(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name: "deis-router@1.service",
@@ -41,6 +43,8 @@ func TestUnits(t *testing.T) {
 }
 
 func TestNextUnit(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name: "deis-router@1.service",
@@ -66,6 +70,8 @@ func TestNextUnit(t *testing.T) {
 }
 
 func TestLastUnit(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name: "deis-router@1.service",
@@ -91,6 +97,8 @@ func TestLastUnit(t *testing.T) {
 }
 
 func TestFormatUnitName(t *testing.T) {
+	t.Parallel()
+
 	unitName, err := formatUnitName("router", 1)
 	if err != nil {
 		t.Fatal(err)
@@ -102,6 +110,8 @@ func TestFormatUnitName(t *testing.T) {
 }
 
 func TestNewUnit(t *testing.T) {
+	t.Parallel()
+
 	name, err := ioutil.TempDir("", "deisctl-fleetctl")
 	unitFile := `[Unit]
 Description=deis-controller`
@@ -124,6 +134,8 @@ Description=deis-controller`
 }
 
 func TestReadTemplate(t *testing.T) {
+	t.Parallel()
+
 	name, err := ioutil.TempDir("", "deisctl-fleetctl")
 	expected := []byte("test")
 
@@ -146,6 +158,8 @@ func TestReadTemplate(t *testing.T) {
 }
 
 func TestReadTemplateError(t *testing.T) {
+	t.Parallel()
+
 	name, err := ioutil.TempDir("", "deisctl-fleetctl")
 
 	if err != nil {
diff --git a/deisctl/backend/fleet/utils_test.go b/deisctl/backend/fleet/utils_test.go
@@ -10,6 +10,8 @@ import (
 )
 
 func TestNextComponent(t *testing.T) {
+	t.Parallel()
+
 	// test first component
 	num, err := nextUnitNum([]string{})
 	if err != nil {
@@ -65,6 +67,8 @@ func TestNextComponent(t *testing.T) {
 }
 
 func TestLastComponent(t *testing.T) {
+	t.Parallel()
+
 	num, err := lastUnitNum([]string{})
 	errorf := fmt.Sprintf("%v", err)
 	expectedErr := "Component not found"
@@ -115,6 +119,8 @@ func TestLastComponent(t *testing.T) {
 }
 
 func TestSplitJobName(t *testing.T) {
+	t.Parallel()
+
 	c, num, err := splitJobName("deis-router@1.service")
 	if err != nil {
 		t.Fatal(err)
@@ -125,6 +131,8 @@ func TestSplitJobName(t *testing.T) {
 }
 
 func TestSplitTarget(t *testing.T) {
+	t.Parallel()
+
 	c, num, err := splitTarget("router")
 	if err != nil {
 		t.Fatal(err)
@@ -152,6 +160,8 @@ func TestSplitTarget(t *testing.T) {
 }
 
 func TestExpandTargets(t *testing.T) {
+	t.Parallel()
+
 	testUnits := []*schema.Unit{
 		&schema.Unit{
 			Name: "deis-router@1.service",
diff --git a/deisctl/cmd/cmd_test.go b/deisctl/cmd/cmd_test.go
diff --git a/deisctl/config/config_test.go b/deisctl/config/config_test.go
diff --git a/deisctl/utils/utils_test.go b/deisctl/utils/utils_test.go

Original file line number	Diff line number	Diff line change
`@@ -11,6 +11,7 @@ import (`
`11`	`11`	`)`
`12`	`12`
`13`	`13`	`func TestCreate(t *testing.T) {`
	`14`	`+ t.Parallel()`
`14`	`15`
`15`	`16`	`unitFiles := []string{"deis-controller.service", "deis-builder.service",`
`16`	`17`	`"deis-router.service"}`
Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,8 @@ import (`
`9`	`9`	`)`
`10`	`10`
`11`	`11`	`func TestDestroy(t *testing.T) {`
	`12`	`+ t.Parallel()`
	`13`	`+`
`12`	`14`	`testUnits := []*schema.Unit{`
`13`	`15`	`&schema.Unit{`
`14`	`16`	`Name: "deis-registry.service",`
Original file line number	Diff line number	Diff line change
`@@ -127,6 +127,8 @@ func logState(outchan chan string, errchan chan error, errOutput *string, mutex`
`127`	`127`	`}`
`128`	`128`
`129`	`129`	`func TestNewClient(t *testing.T) {`
	`130`	`+ t.Parallel()`
	`131`	`+`
`130`	`132`	`// set required flags`
`131`	`133`	`Flags.Endpoint = "http://127.0.0.1:4001"`
`132`	`134`
Original file line number	Diff line number	Diff line change
`@@ -34,6 +34,8 @@ func (m mockJournalCommandRunner) RemoteCommand(cmd string, addr string, timeout`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`func TestJournal(t *testing.T) {`
	`37`	`+ t.Parallel()`
	`38`	`+`
`37`	`39`	`testMachines := []machine.MachineState{`
`38`	`40`	`machine.MachineState{`
`39`	`41`	`ID: "test-1",`
Original file line number	Diff line number	Diff line change
`@@ -12,6 +12,7 @@ import (`
`12`	`12`	`)`
`13`	`13`
`14`	`14`	`func TestListUnitFiles(t *testing.T) {`
	`15`	`+ t.Parallel()`
`15`	`16`
`16`	`17`	`testUnits := []*schema.Unit{`
`17`	`18`	`&schema.Unit{`