k6 – 使用Go客户端创建自定义资源

huangapple
go评论116阅读模式
英文:

k6 - create custom resource using go client

问题

有人知道如何使用go-client创建自定义资源吗？基本上相当于kubectl apply -f 'yaml路径'

  1. apiVersion: k6.io/v1alpha1
  2. kind: K6
  3. metadata:
  4.   name: k6-sample
  5. spec:
  6.   parallelism: 1
  7.   #arguments: --out statsd
  8.   #cleanup: post
  9.   script:
  10.     configMap:
  11.       name: "staging-stress-test"
  12.       file: "staging.js"

以下是生成自定义资源的go-client代码

  1. func createk6CR(clientset *kubernetes.Clientset) (string, error) {
  3. 	k6plugin := &v1alpha1.K6{
  4. 		TypeMeta: metav1.TypeMeta{
  5. 			APIVersion: "k6.io/v1alpha1",
  6. 			Kind:       "K6",
  7. 		},
  8. 		ObjectMeta: metav1.ObjectMeta{
  9. 			Name:      "k6-sample-1",
  10. 			Namespace: "default",
  11. 		},
  12. 		Spec: v1alpha1.K6Spec{
  13. 			Parallelism: 3,
  14. 			Script: v1alpha1.K6Script{
  15. 				ConfigMap: v1alpha1.K6Configmap{
  16. 					Name: "staging-stress-test",
  17. 					File: "staging.js",
  18. 				},
  19. 			},
  20. 		},
  21. 		// Status: v1alpha1.K6Status{
  22. 		// 	Stage: "started",
  23. 		// },
  24. 	}
  26. 	body, err := json.Marshal(k6plugin)
  28. 	if err != nil {
  29. 		fmt.Printf("error getting Kubernetes config: %v\n", err)
  30. 		os.Exit(1)
  31. 	}
  33. 	data, err := clientset.RESTClient().
  34. 		Post().
  35. 		AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6").
  36. 		Body(body).
  37. 		DoRaw(context.TODO())
  39. 	if data != nil {
  40. 		str := string(data[:])
  42. 		fmt.Printf("return data: %v\n", str)
  43. 		//os.Exit(1)
  44. 	}
  46. 	return "success", err
  47. }

但是在AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6")上我得到了404页面未找到的错误。

英文:

Anyone know how to create a Custom Resource using go-client. basically equivalent of kubectl apply -f 'yaml path'

  1. apiVersion: k6.io/v1alpha1
  2. kind: K6
  3. metadata:
  4.   name: k6-sample
  5. spec:
  6.   parallelism: 1
  7.   #arguments: --out statsd
  8.   #cleanup: post
  9.   script:
  10.     configMap:
  11.       name: "staging-stress-test"
  12.       file: "staging.js"

Have a go-client code to generate a Custom Resource below

  1. func createk6CR(clientset *kubernetes.Clientset) (string, error) {
  3. 	k6plugin := &v1alpha1.K6{
  4. 		TypeMeta: metav1.TypeMeta{
  5. 			APIVersion: "k6.io/v1alpha1",
  6. 			Kind:       "K6",
  7. 		},
  8. 		ObjectMeta: metav1.ObjectMeta{
  9. 			Name:      "k6-sample-1",
  10. 			Namespace: "default",
  11. 		},
  12. 		Spec: v1alpha1.K6Spec{
  13. 			Parallelism: 3,
  14. 			Script: v1alpha1.K6Script{
  15. 				ConfigMap: v1alpha1.K6Configmap{
  16. 					Name: "staging-stress-test",
  17. 					File: "staging.js",
  18. 				},
  19. 			},
  20. 		},
  21. 		// Status: v1alpha1.K6Status{
  22. 		// 	Stage: "started",
  23. 		// },
  24. 	}
  26. 	body, err := json.Marshal(k6plugin)
  28. 	if err != nil {
  29. 		fmt.Printf("error getting Kubernetes config: %v\n", err)
  30. 		os.Exit(1)
  31. 	}
  33. 	data, err := clientset.RESTClient().
  34. 		Post().
  35. 		AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6").
  36. 		Body(body).
  37. 		DoRaw(context.TODO())
  39. 	if data != nil {
  40. 		str := string(data[:])
  42. 		fmt.Printf("return data: %v\n", str)
  43. 		//os.Exit(1)
  44. 	}
  46. 	return "success", err
  47. }

But I get Page 404 not found on AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6").

答案1

得分: 1

发现了问题所在，当你执行 kubectl apply 命令时，使用 -v 8 参数来查看 POST 请求的 Abspath 检查。

kubectl apply -f '资源路径'

修正后的代码如下：

  1. data, err := clientset.RESTClient().
  2. Post().
  3. AbsPath("/apis/k6.io/v1alpha1/namespaces/default/k6s").
  4. Body(body).
  5. DoRaw(context.TODO())
英文:

Found what was wrong with it, when you do kubectl apply pass it with -v 8 to see the Abspath check for POST

kubectl apply -f 'resource path' 

  1. 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
  2. I0816 09:20:56.239428   15535 round_trippers.go:469] Request Headers:

so the code with corrected AbsPath should be below,

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

huangapple
  • 本文由 发表于 2022年8月16日 02:46:02
  • 转载请务必保留本文链接：https://go.coder-hub.com/73365206.html
  • go
  • k6
  • kubernetes-custom-resources
  • kubernetes-go-client
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定