feat(install): add docker

* Update parallel
* Update kind
* Add dockerfile for agent

Author: ernado

agent.Dockerfile

@@ -0,0 +1,5 @@
+FROM ubuntu
+
+COPY _out/bin/vega-agent /usr/local/bin/vega-agent
+
+ENTRYPOINT ["/usr/local/bin/vega-agent"]

cmd/vega-install/main.go

@@ -21,7 +21,15 @@ func run(ctx context.Context) error {
 				installer.BuildBinary("vega"),
 			},
 		},
-		&installer.Kind{},
+		&installer.Docker{
+			Tags:    []string{"vega-agent:latest"},
+			File:    "agent.Dockerfile",
+			Context: ".",
+		},
+		&installer.Kind{
+			Name:   "vega",
+			Config: "_hack/vega.kind.yml",
+		},
 	}
 	for _, step := range steps {
 		fmt.Println("step:", step.Step().Name)

internal/installer/docker.go

@@ -0,0 +1,44 @@
+package installer
+
+import (
+	"context"
+	"os"
+	"os/exec"
+
+	"github.com/go-faster/errors"
+)
+
+type Docker struct {
+	Bin     string
+	Tags    []string
+	File    string
+	Context string
+}
+
+func (d Docker) Step() StepInfo {
+	return StepInfo{Name: "docker:" + d.Tags[0]}
+}
+
+func (d Docker) Run(ctx context.Context) error {
+	b := d.Bin
+	if b == "" {
+		b = "docker"
+	}
+	if d.Context == "" {
+		d.Context = "."
+	}
+	arg := []string{
+		"build", "-f", d.File,
+	}
+	for _, tag := range d.Tags {
+		arg = append(arg, "-t", tag)
+	}
+	arg = append(arg, d.Context)
+	cmd := exec.CommandContext(ctx, b, arg...)
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	if err := cmd.Run(); err != nil {
+		return errors.Wrap(err, "create cluster")
+	}
+	return nil
+}

internal/installer/kind.go

@@ -10,17 +10,25 @@ import (
 
 // Kind is Kubernetes In Docker (KIND) installer.
 type Kind struct {
-	Bin string
+	Bin    string
+	Name   string
+	Config string
 }
 
 func (k Kind) Run(ctx context.Context) error {
 	b := k.Bin
 	if b == "" {
 		b = "kind"
 	}
+	if k.Name == "" {
+		k.Name = "vega"
+	}
 	arg := []string{
 		"create", "cluster",
-		"-n", "vega",
+		"-n", k.Name,
+	}
+	if k.Config != "" {
+		arg = append(arg, "--config", k.Config)
 	}
 	cmd := exec.CommandContext(ctx, b, arg...)
 	cmd.Stdout = os.Stdout

internal/installer/parallel.go

@@ -2,6 +2,7 @@ package installer
 
 import (
 	"context"
+	"fmt"
 	"strings"
 
 	"golang.org/x/sync/errgroup"
@@ -41,6 +42,7 @@ func (p *Parallel) Run(ctx context.Context) error {
 			defer func() {
 				<-sema
 			}()
+			fmt.Println("> step:", s.Step().Name)
 			return s.Run(ctx)
 		})
 	}