refactor: default command to container-metric

Makefile

@@ -1,3 +1,11 @@
 fmt:
 	go fmt ./...
 .PHONY: fmt
+
+lint:
+	golangci-lint run -E goimports -E godot --timeout 10m
+.PHONY: lint
+
+test:
+	go test ./...
+.PHONY: test

docker-compose.yml

@@ -18,4 +18,7 @@ services:
     ports:
       - 8080:8080
     labels:
-      pipemgr.enable: true
+      pipemgr.enable: false
+    depends_on:
+      pipemgr:
+        condition: service_healthy

main.go

@@ -16,7 +16,6 @@ import (
 	"github.com/docker/docker/api/types/events"
 	"github.com/docker/docker/client"
 	"github.com/picosh/utils/pipe"
-	"github.com/picosh/utils/pipe/metrics"
 )
 
 func createDockerClient() *client.Client {
@@ -85,6 +84,7 @@ func main() {
 	remoteUserFlag := flag.String("remote-user", "", "The remote user to connect as")
 	keyLocationFlag := flag.String("remote-key-location", "/key", "The location on the filesystem of where to access the ssh key")
 	keyPassphraseFlag := flag.String("remote-key-passphrase", "", "The passphrase for an encrypted ssh key")
+	command := flag.String("command", "pub container-drain -b=false", "The command to run for the remote session")
 
 	flag.Parse()
 
@@ -142,10 +142,12 @@ func main() {
 	}
 	ctx := context.Background()
 
-	reconn := metrics.RegisterReconnectMetricRecorder(
+	reconn := pipe.NewReconnectReadWriteCloser(
 		ctx,
 		rootLogger,
 		info,
+		"pipemgr",
+		*command,
 		100,
 		10*time.Millisecond,
 	)