test: add 'piko test cluster'

Adds 'piko test cluster' to run a local Piko cluster.

cli/command.go

@@ -7,7 +7,6 @@ import (
 	"github.com/andydunstall/piko/cli/forward"
 	"github.com/andydunstall/piko/cli/server"
 	"github.com/andydunstall/piko/cli/test"
-	workloadv2 "github.com/andydunstall/piko/cli/workloadv2"
 	"github.com/andydunstall/piko/pkg/build"
 )
 
@@ -65,7 +64,6 @@ to an upstream listener via Piko. Such as to forward port 3000 to endpoint
 	cmd.AddCommand(agent.NewCommand())
 	cmd.AddCommand(forward.NewCommand())
 	cmd.AddCommand(test.NewCommand())
-	cmd.AddCommand(workloadv2.NewCommand())
 
 	return cmd
 }

cli/workloadv2/cluster.go → cli/test/cluster/command.go

@@ -1,4 +1,4 @@
-package workload
+package cluster
 
 import (
 	"context"
@@ -11,15 +11,15 @@ import (
 	"github.com/spf13/cobra"
 	"go.uber.org/zap"
 
+	"github.com/andydunstall/piko/pikotest/cluster"
+	"github.com/andydunstall/piko/pikotest/cluster/config"
+	"github.com/andydunstall/piko/pikotest/cluster/proxy"
 	"github.com/andydunstall/piko/pkg/build"
 	pikoconfig "github.com/andydunstall/piko/pkg/config"
 	"github.com/andydunstall/piko/pkg/log"
-	"github.com/andydunstall/piko/workloadv2/cluster"
-	"github.com/andydunstall/piko/workloadv2/cluster/config"
-	"github.com/andydunstall/piko/workloadv2/cluster/proxy"
 )
 
-func newClusterCommand() *cobra.Command {
+func NewCommand() *cobra.Command {
 	cmd := &cobra.Command{
 		Use:   "cluster",
 		Short: "create a cluster of Piko nodes",

cli/test/command.go

@@ -3,6 +3,7 @@ package test
 import (
 	"github.com/spf13/cobra"
 
+	"github.com/andydunstall/piko/cli/test/cluster"
 	"github.com/andydunstall/piko/cli/test/workload"
 )
 
@@ -14,6 +15,7 @@ func NewCommand() *cobra.Command {
 	}
 
 	cmd.AddCommand(workload.NewCommand())
+	cmd.AddCommand(cluster.NewCommand())
 
 	return cmd
 }

workloadv2/cluster/manager.go → pikotest/cluster/manager.go

@@ -5,8 +5,8 @@ import (
 
 	"go.uber.org/zap"
 
+	"github.com/andydunstall/piko/pikotest/cluster/config"
 	"github.com/andydunstall/piko/pkg/log"
-	"github.com/andydunstall/piko/workloadv2/cluster/config"
 )
 
 type Manager struct {

workloadv2/cluster/proxy/loadbalancer.go → pikotest/cluster/proxy/loadbalancer.go

@@ -9,7 +9,7 @@ import (
 	"net/http/httputil"
 	"sync"
 
-	"github.com/andydunstall/piko/workloadv2/cluster"
+	"github.com/andydunstall/piko/pikotest/cluster"
 )
 
 type reverseProxy struct {

tests/admin_test.go

@@ -8,7 +8,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	cluster "github.com/andydunstall/piko/workloadv2/cluster"
+	cluster "github.com/andydunstall/piko/pikotest/cluster"
 )
 
 // Tests the admin server.

tests/auth_test.go

@@ -13,8 +13,8 @@ import (
 	"github.com/stretchr/testify/assert"
 
 	"github.com/andydunstall/piko/client"
+	"github.com/andydunstall/piko/pikotest/cluster"
 	"github.com/andydunstall/piko/server/auth"
-	"github.com/andydunstall/piko/workloadv2/cluster"
 )
 
 type pikoEndpointClaims struct {

tests/client_test.go

@@ -15,7 +15,7 @@ import (
 	"github.com/stretchr/testify/assert"
 
 	"github.com/andydunstall/piko/client"
-	cluster "github.com/andydunstall/piko/workloadv2/cluster"
+	"github.com/andydunstall/piko/pikotest/cluster"
 )
 
 // TestClient_ListenAndForward tests forwarding incoming connections to a local

tests/cluster_test.go

@@ -14,8 +14,8 @@ import (
 	"github.com/stretchr/testify/assert"
 
 	"github.com/andydunstall/piko/client"
-	"github.com/andydunstall/piko/workloadv2/cluster"
-	"github.com/andydunstall/piko/workloadv2/cluster/config"
+	"github.com/andydunstall/piko/pikotest/cluster"
+	"github.com/andydunstall/piko/pikotest/cluster/config"
 )
 
 // Tests proxying traffic across multiple Piko server nodes.

tests/proxy_test.go

@@ -21,7 +21,7 @@ import (
 	"github.com/stretchr/testify/assert"
 
 	"github.com/andydunstall/piko/client"
-	cluster "github.com/andydunstall/piko/workloadv2/cluster"
+	"github.com/andydunstall/piko/pikotest/cluster"
 )
 
 type errorMessage struct {