feat(longhorn): collect from log-path

longhorn/longhorn-11522

Signed-off-by: Chin-Ya Huang <[email protected]>

Author: c3y1huang

hack/collector-longhorn

@@ -58,6 +58,24 @@ function collect_kubelet_log(){
     fi
 }
 
+collect_longhorn_logs() {
+    local src_dir
+    src_dir=$(join_paths "$HOST_PATH" "$LONGHORN_LOG_PATH")
+
+    if [ -d "$src_dir" ]; then
+        cp -r "$src_dir"/* .
+    else
+        echo "Longhorn log directory not found: $src_dir" >&2
+    fi
+}
+
+join_paths() {
+    local base="$1"
+    local sub="$2"
+    # Remove trailing slash from base and leading slash from sub
+    printf "%s/%s\n" "${base%/}" "${sub#/}"
+}
+
 function collect_logs(){
     cd ${BUNDLE_DIR}
     mkdir -p logs
@@ -66,6 +84,7 @@ function collect_logs(){
     collect_dmesg
     collect_syslog
     collect_kubelet_log
+    collect_longhorn_logs
 }
 
 collect_sysinfo

pkg/manager/agent.go

@@ -2,6 +2,7 @@ package manager
 
 import (
 	"fmt"
+	"os"
 
 	"github.com/pkg/errors"
 	"github.com/sirupsen/logrus"
@@ -138,9 +139,21 @@ func (a *AgentDaemonSet) Create(image string, managerURL string) (*appsv1.Daemon
 		}
 	}
 
+	switch a.sbm.SpecifyCollector {
+	case "longhorn":
+		a.prepareDaemonSetForLonghorn(daemonSet)
+	}
+
 	return a.sbm.k8s.CreateDaemonSets(a.sbm.PodNamespace, daemonSet)
 }
 
+func (a *AgentDaemonSet) prepareDaemonSetForLonghorn(daemonset *appsv1.DaemonSet) {
+	daemonset.Spec.Template.Spec.Containers[0].Env = append(daemonset.Spec.Template.Spec.Containers[0].Env, corev1.EnvVar{
+		Name:  "LONGHORN_LOG_PATH",
+		Value: os.Getenv("LONGHORN_LOG_PATH"),
+	})
+}
+
 func (a *AgentDaemonSet) Cleanup() error {
 	dsName := a.getDaemonSetName()
 	err := a.sbm.k8s.DeleteDaemonSets(a.sbm.PodNamespace, dsName)