如何使用Go从kubernetes获取日志？

package main

import (
    "context"
    "fmt"
    "log"
    "path/filepath"

    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"
)

func main() {
    var kubeconfig string
    if home := homedir.HomeDir(); home != "" {
        kubeconfig = filepath.Join(home, ".kube", "config")
    } else {
        log.Fatal("Unable to find kubeconfig")
    }

    config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
    if err != nil {
        log.Fatalf("Error building kubeconfig: %s", err.Error())
    }

    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        log.Fatalf("Error creating clientset: %s", err.Error())
    }

    podName := "your-pod-name"
    namespace := "default"

    req := clientset.CoreV1().Pods(namespace).GetLogs(podName, &v1.PodLogOptions{})
    podLogs, err := req.Stream(context.TODO())
    if err != nil {
        log.Fatalf("Error opening stream: %s", err.Error())
    }
    defer podLogs.Close()

    buf := new(bytes.Buffer)
    _, err = buf.ReadFrom(podLogs)
    if err != nil {
        log.Fatalf("Error reading from pod logs: %s", err.Error())
    }

    fmt.Println(buf.String())
}