Add operator logs

Signed-off-by: Israel Blancas <[email protected]>

Author: iblancasa

cmd/gather/cluster/cluster.go

@@ -70,6 +70,31 @@ func (c *Cluster) getOperatorDeployment() (appsv1.Deployment, error) {
 
 }
 
+func (c *Cluster) GetOperatorLogs() error {
+	deployment, err := c.getOperatorDeployment()
+	if err != nil {
+		return err
+	}
+
+	labelSelector := labels.Set(deployment.Spec.Selector.MatchLabels).AsSelectorPreValidated()
+	operatorPods := corev1.PodList{}
+	err = c.config.KubernetesClient.List(context.TODO(), &operatorPods, &client.ListOptions{
+		LabelSelector: labelSelector,
+	})
+	if err != nil {
+		return err
+	}
+
+	pod := operatorPods.Items[0]
+	c.getPodLogs(pod.Name, pod.Namespace, "manager")
+	return nil
+}
+
+func (c *Cluster) getPodLogs(podName, namespace, container string) {
+	pods := c.config.KubernetesClientSet.CoreV1().Pods(namespace)
+	writeLogToFile(c.config.CollectionDir, podName, container, pods)
+}
+
 func (c *Cluster) GetOperatorDeploymentInfo() error {
 	err := os.MkdirAll(c.config.CollectionDir, os.ModePerm)
 	if err != nil {

cmd/gather/cluster/write.go

@@ -1,17 +1,21 @@
 package cluster
 
 import (
+	"context"
 	"fmt"
+	"io"
 	"log"
 	"os"
 	"path/filepath"
 	"reflect"
 	"strings"
 
 	"github.com/open-telemetry/opentelemetry-operator/apis/v1beta1"
+	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/serializer/json"
+	cgocorev1 "k8s.io/client-go/kubernetes/typed/core/v1"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
@@ -44,6 +48,33 @@ func createFile(outputDir string, obj client.Object) (*os.File, error) {
 	return os.Create(path)
 }
 
+func writeLogToFile(outputDir, podName, container string, p cgocorev1.PodInterface) {
+	req := p.GetLogs(podName, &corev1.PodLogOptions{Container: container})
+	podLogs, err := req.Stream(context.Background())
+	if err != nil {
+		log.Fatalf("Error getting pod logs: %v\n", err)
+		return
+	}
+	defer podLogs.Close()
+
+	err = os.MkdirAll(outputDir, os.ModePerm)
+	if err != nil {
+		log.Fatalln(err)
+		return
+	}
+
+	outputFile, err := os.Create(filepath.Join(outputDir, podName))
+	if err != nil {
+		log.Fatalf("Error getting pod logs: %v\n", err)
+		return
+	}
+
+	_, err = io.Copy(outputFile, podLogs)
+	if err != nil {
+		log.Fatalf("Error copying logs to file: %v\n", err)
+	}
+}
+
 func writeToFile(outputDir string, o client.Object) {
 	// Open or create the file for writing
 	outputFile, err := createFile(outputDir, o)

cmd/gather/config/config.go

@@ -6,16 +6,18 @@ import (
 
 	"github.com/spf13/pflag"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/tools/clientcmd"
 	"k8s.io/client-go/util/homedir"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
 type Config struct {
-	CollectionDir     string
-	OperatorName      string
-	OperatorNamespace string
-	KubernetesClient  client.Client
+	CollectionDir       string
+	OperatorName        string
+	OperatorNamespace   string
+	KubernetesClient    client.Client
+	KubernetesClientSet *kubernetes.Clientset
 }
 
 func NewConfig(scheme *runtime.Scheme) (Config, error) {
@@ -37,10 +39,16 @@ func NewConfig(scheme *runtime.Scheme) (Config, error) {
 		return Config{}, fmt.Errorf("Creating the Kubernetes client: %s\n", err)
 	}
 
+	clientset, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		return Config{}, fmt.Errorf("Creating the Kubernetes clienset: %s\n", err)
+	}
+
 	return Config{
-		CollectionDir:     collectionDir,
-		KubernetesClient:  clusterClient,
-		OperatorName:      operatorName,
-		OperatorNamespace: operatorNamespace,
+		CollectionDir:       collectionDir,
+		KubernetesClient:    clusterClient,
+		KubernetesClientSet: clientset,
+		OperatorName:        operatorName,
+		OperatorNamespace:   operatorNamespace,
 	}, nil
 }

cmd/gather/main.go

@@ -48,6 +48,7 @@ func main() {
 	}
 
 	cluster := cluster.NewCluster(&config)
+	cluster.GetOperatorLogs()
 	cluster.GetOperatorDeploymentInfo()
 	cluster.GetOLMInfo()
 	cluster.GetOpenTelemetryCollectors()