Получить данные Pod spe c в структурную переменную - PullRequest
Новая
       37

Получить данные Pod spe c в структурную переменную

0 голосов
/ 09 января 2020

Я пытался получить информацию о пакете и заполнить их в полях структуры. Тем не менее, я получаю ошибку при заполнении деталей в структуру. 

package main

import (
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    // corev1"k8s.io/api/core/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
)

type PodsList struct{
    podNamespace    string
    podName     string
}

func main() {
   var targetPods []TargetPodsList

   config, inClusterConfigError := rest.InClusterConfig()
    if inClusterConfigError != nil {
        fmt.Println("Retrieval of K8s InCluster Config not successful")
        log.Fatal(inClusterConfigError)
    }

    // Set k8s client configuration
    clientset, clientSetError := kubernetes.NewForConfig(config)
    if clientSetError != nil {
        fmt.Println("K8s Client for Incluster Configuration not successful")
        log.Fatal(clientSetError)
    }

    // Retrieve Pods for all target K8s nodes
    for index := range targetNodes.TargetNodes {
        targetPodsList, _ := clientset.CoreV1().Pods("").List(metav1.ListOptions{
            FieldSelector: "spec.nodeName=" + someNodeName)
        for podIndex := range targetPodsList.Items {
            targetPods.podNamespace = targetPods[podIndex].podNamespace
            targetPods.podName = targetPods[podIndex].podName
        }
    }
}

Я знаю, что это базовая c вещь, которую я могу упустить.

Пожалуйста, предложите и исправьте мой код.

Заранее спасибо.

1 Ответ

0 голосов
/ 09 января 2020

код здесь. 

package main

import (
    "flag"
    "fmt"
    "os"
    "path/filepath"

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

func main() {
    // creates the in-cluster config
    config, err := rest.InClusterConfig()
    if err != nil {
        // creates the out-of-cluster config
        var kubeconfig *string
        if home := os.Getenv("HOME"); home != "" {
            kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
        } else {
            kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
        }
        flag.Parse()

        // use the current context in kubeconfig
        config, err = clientcmd.BuildConfigFromFlags("", *kubeconfig)
        if err != nil {
            panic(err.Error())
        }
    }

    // creates the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }

    // fetch all pod name, namespace in "default" namespace
    pods, err := clientset.CoreV1().Pods("default").List(metav1.ListOptions{})
    for _, pod := range pods.Items {
        fmt.Printf("pod name: %s namespace: %s\n", pod.ObjectMeta.GetName(), pod.ObjectMeta.GetNamespace())
    }
}

запустите этот код. 

$ kubectl get pod
NAME         READY   STATUS    RESTARTS   AGE
nginx-pod    1/1     Running   0          92m
nginx-pod2   1/1     Running   0          21s

$ go run main.go
pod name: nginx-pod namespace: default
pod name: nginx-pod2 namespace: default

, и вы можете увидеть примеры клиентских go здесь .

...