使用 kubernetes 客户端 API 创建 pod 时出错

夜猫子19

我正在尝试在 Go 中使用 Kubernetes 客户端 api 创建一个 pod，但我在 TravisCI 中遇到了以下错误，

ERRO Running error: buildir: analysis skipped: errors in package: [/home/travis/gopath/src/github.com/pravarag/test-repo/check_pod.go:25:70: cannot use desiredPod (variable of type *"k8s.io/api/core/v1".Pod) as context.Context value in argument to s.kubeClient.CoreV1().Pods(desiredPod.Namespace).Create: missing method Deadline /home/travis/gopath/src/github.com/pravarag/test-repo/check_pod.go:25:80: too few arguments in call to s.kubeClient.CoreV1().Pods(desiredPod.Namespace).Create

下面是代码，

import (
    "fmt"

    "go.uber.org/zap"
    core "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func (s *server) createPod() {
    // build the pod definition
    desiredPod := getPodObjet()

    pod, err := s.kubeClient.CoreV1().Pods(desiredPod.Namespace).Create(desiredPod)
    if err != nil {
        s.log.Fatal("Failed to create the static pod", zap.Error(err))
    }
    fmt.Println("Created Pod: ", pod.Name)
}

func getPodObjet() *core.Pod {
    pod := &core.Pod{
        ObjectMeta: metav1.ObjectMeta{
            Name:      "test-pod",
            Namespace: "default",
            Labels: map[string]string{
                "app": "test-pod",
            },
        },
        Spec: core.PodSpec{
            Containers: []core.Container{
                {
                    Name:            "busybox",
                    Image:           "busybox",
                    ImagePullPolicy: core.PullIfNotPresent,
                    Command: []string{
                        "sleep",
                        "3600",
                    },
                },
            },
        },
    }
    return pod
}

我试图检查什么错误指向，似乎在K8S客户端代码的实际荚界面在这里：https://godoc.org/k8s.io/client-go/kubernetes/typed/core/v1#PodInterface期待3个参数：一个是"context.Context"，"pod *v1.Pod"和"opts metav1.CreateOptions"我试图传递值：

pod, err :=s.kubeClient.CoreV1().Pods(desiredPod.Namespace).Create(context.Context, desiredPod, opts metav1.CreateOptions{})

但这也行不通。即使在 IDE 中，代码 lint 也指向缺少的参数，但我已经看到几个示例用于以上述方式创建一个 pod，以前的工作方式。

埃蒙46

仅用context.TODO()作传递上下文的参数。

试试这个。

pod, err := s.kubeClient.CoreV1().Pods(desiredPod.Namespace).Create( context.TODO(), desiredPod , metav1.CreateOptions{})

这是更新的代码：

import (
    "fmt"

    "context"

    "go.uber.org/zap"
    core "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func (s *server) createPod() {
    // build the pod definition
    desiredPod := getPodObjet()

    pod, err := s.kubeClient.CoreV1().Pods(desiredPod.Namespace).Create( context.TODO(), desiredPod , metav1.CreateOptions{})
    if err != nil {
        s.log.Fatal("Failed to create the static pod", zap.Error(err))
    }
    fmt.Println("Created Pod: ", pod.Name)
}

func getPodObjet() *core.Pod {
    pod := &core.Pod{
        ObjectMeta: metav1.ObjectMeta{
            Name:      "test-pod",
            Namespace: "default",
            Labels: map[string]string{
                "app": "test-pod",
            },
        },
        Spec: core.PodSpec{
            Containers: []core.Container{
                {
                    Name:            "busybox",
                    Image:           "busybox",
                    ImagePullPolicy: core.PullIfNotPresent,
                    Command: []string{
                        "sleep",
                        "3600",
                    },
                },
            },
        },
    }
    return pod
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。