Tail OpenTelemetry container logs

internal/infra/open_telemetry.go

@@ -3,15 +3,19 @@ package infra
 import (
 	"context"
 	"fmt"
+	"io"
+	"log"
+	"os"
+	"path"
+	"path/filepath"
+
 	"github.com/docker/docker/api/types"
 	"github.com/docker/docker/api/types/container"
 	"github.com/docker/docker/api/types/mount"
 	"github.com/docker/docker/api/types/network"
+	"github.com/goware/prefixer"
 	"github.com/moby/moby/client"
-	"log"
-	"os"
-	"path"
-	"path/filepath"
+	"github.com/moby/moby/pkg/stdcopy"
 )
 
 // CollectorImageName is the default Docker image used
@@ -101,7 +105,23 @@ func NewCollector(ctx context.Context, cli *client.Client, net *Networks, params
 	}
 
 	return collector, nil
+}
+
+func (c *Collector) TailLogs(ctx context.Context, cli *client.Client) {
+	out, err := cli.ContainerLogs(ctx, c.containerID, container.LogsOptions{
+		ShowStdout: true,
+		ShowStderr: true,
+		Follow:     true,
+	})
+	if err != nil {
+		return
+	}
 
+	r, w := io.Pipe()
+	go func() {
+		_, _ = io.Copy(os.Stderr, prefixer.New(r, "   otel | "))
+	}()
+	_, _ = stdcopy.StdCopy(w, w, out)
 }
 
 // Close stops and removes the container.

internal/infra/run.go

@@ -394,6 +394,9 @@ func runContainers(ctx context.Context, params RunParams) (err error) {
 		if err != nil {
 			fmt.Println("Failed to create OpenTelemetry collector:", err)
 		}
+		if !params.Debug {
+			go collector.TailLogs(ctx, cli)
+		}
 		defer collector.Close()
 	}