k6 - 使用 go 客户端创建自定义资源

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《k6 - 使用 go 客户端创建自定义资源》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

任何人都知道如何使用 go-client 创建自定义资源。基本上相当于 kubectl apply -f 'yaml path'

apiversion: k6.io/v1alpha1
kind: k6
metadata:
  name: k6-sample
spec:
  parallelism: 1
  #arguments: --out statsd
  #cleanup: post
  script:
    configmap:
      name: "staging-stress-test"
      file: "staging.js"

有一个 go-client 代码来生成下面的自定义资源

func createk6CR(clientset *kubernetes.Clientset) (string, error) {

    k6plugin := &v1alpha1.K6{
        TypeMeta: metav1.TypeMeta{
            APIVersion: "k6.io/v1alpha1",
            Kind:       "K6",
        },
        ObjectMeta: metav1.ObjectMeta{
            Name:      "k6-sample-1",
            Namespace: "default",
        },
        Spec: v1alpha1.K6Spec{
            Parallelism: 3,
            Script: v1alpha1.K6Script{
                ConfigMap: v1alpha1.K6Configmap{
                    Name: "staging-stress-test",
                    File: "staging.js",
                },
            },
        },
        // Status: v1alpha1.K6Status{
        //  Stage: "started",
        // },
    }

    body, err := json.Marshal(k6plugin)

    if err != nil {
        fmt.Printf("error getting Kubernetes config: %v\n", err)
        os.Exit(1)
    }

    data, err := clientset.RESTClient().
        Post().
        AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6").
        Body(body).
        DoRaw(context.TODO())

    if data != nil {
        str := string(data[:])

        fmt.Printf("return data: %v\n", str)
        //os.Exit(1)
    }

    return "success", err
}

但是我在 abspath("/apis/k6.io/v1alpha1/namespaces/default/k6") 上找不到 page 404。

正确答案

发现它出了什么问题，当您执行 kubectl apply 时，使用 -v 8 传递它以查看 post 的 abspath 检查

kubectl apply -f '资源路径'

i0816 09:20:56.239402   15535 round_trippers.go:463] post https://0.0.0.0:43117/apis/k6.io/v1alpha1/namespaces/default/k6s?fieldmanager=kubectl-client-side-apply&fieldvalidation=strict
i0816 09:20:56.239428   15535 round_trippers.go:469] request headers:

所以带有正确的 abspath 的代码应该如下，

data, err := clientset.RESTClient().
        Post().
        AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6s").
        Body(body).
        DoRaw(context.TODO())

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《k6 - 使用 go 客户端创建自定义资源》文章吧，也可关注golang学习网公众号了解相关技术文章。