chore: log metricbeat container logs

It will happen if and only if the log level is DEBUG

Author: mdelapenya

cli/services/manager.go

@@ -15,6 +15,7 @@ import (
 type ServiceManager interface {
 	AddServicesToCompose(stack string, composeNames []string, env map[string]string) error
 	RemoveServicesFromCompose(stack string, composeNames []string, env map[string]string) error
+	RunCommand(stack string, composeNames []string, composeArgs []string, env map[string]string) error
 	RunCompose(isStack bool, composeNames []string, env map[string]string) error
 	StopCompose(isStack bool, composeNames []string) error
 }
@@ -84,6 +85,11 @@ func (sm *DockerServiceManager) RemoveServicesFromCompose(stack string, composeN
 	return nil
 }
 
+// RunCommand executes a docker-compose command in a running a docker compose
+func (sm *DockerServiceManager) RunCommand(stack string, composeNames []string, composeArgs []string, env map[string]string) error {
+	return executeCompose(sm, true, composeNames, composeArgs, env)
+}
+
 // RunCompose runs a docker compose by its name
 func (sm *DockerServiceManager) RunCompose(isStack bool, composeNames []string, env map[string]string) error {
 	return executeCompose(sm, isStack, composeNames, []string{"up", "-d"}, env)

e2e/metricbeat_test.go

@@ -297,6 +297,25 @@ func (mts *MetricbeatTestSuite) runMetricbeatService() error {
 		}).Info("Metricbeat is running")
 	}
 
+	if log.IsLevelEnabled(log.DebugLevel) {
+		composes := []string{
+			"metricbeat", // stack name
+			"metricbeat", // metricbeat service
+		}
+
+		err = serviceManager.RunCommand("metricbeat", composes, []string{"logs", "metricbeat"}, env)
+		if err != nil {
+			log.WithFields(log.Fields{
+				"error":             err,
+				"metricbeatVersion": mts.Version,
+				"service":           mts.ServiceName,
+				"serviceVersion":    mts.ServiceVersion,
+			}).Error("Could not retrieve Metricbeat logs")
+
+			return err
+		}
+	}
+
 	return nil
 }