使用 kubernetes client API 创建 pod 时出错

Question

我正在尝试在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)

}

我试图检查该错误指向什么，似乎K8s客户端代码中的实际pod接口在这里：需要3个参数：一个是，我试图将值传递为：https://godoc.org/k8s.io/client-go/kubernetes/typed/core/v1#PodInterface"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。

Answer 1

只是用作传递上下文的参数。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}