如何在k8s golang客户端中应用HorizontalPodAutoscalers

Question

我正在使用k8s Go客户端，我想在Deployment上应用HorizontalPodAutoscalers。我已经尝试了多次，但它总是返回

{
"error": "the server could not find the requested resource"
}

这是我的代码:

func (k *KubeClient) createAutoScaler(deploymentName string) (*v22.HorizontalPodAutoscaler, error) {
autoscaler := &v22.HorizontalPodAutoscaler{
Spec: v22.HorizontalPodAutoscalerSpec{
ScaleTargetRef: v22.CrossVersionObjectReference{
Kind:       "Deployment",
Name:       deploymentName,
APIVersion: "apps/v1",
},
MinReplicas: pointer.Int32(2),
MaxReplicas: 5,
Metrics: []v22.MetricSpec{
{
Type: v22.ResourceMetricSourceType,
Resource: &v22.ResourceMetricSource{
Name: "cpu",
Target: v22.MetricTarget{
Type:               "Utilization",
AverageUtilization: pointer.Int32(70),
},
},
},
//{
//  Type: v22.ResourceMetricSourceType,
//  Resource: &v22.ResourceMetricSource{
//      Name: "memory",
//      Target: v22.MetricTarget{
//          Type:               "Utilization",
//          AverageUtilization: pointer.Int32(70),
//      },
//  },
//},
},
//Behavior: &v22.HorizontalPodAutoscalerBehavior{
//  ScaleDown: &v22.HPAScalingRules{
//      StabilizationWindowSeconds: pointer.Int32(120),
//      Policies: []v22.HPAScalingPolicy{
//          {
//              Type:          v22.PodsScalingPolicy,
//              Value:         1,
//              PeriodSeconds: 60,
//          },
//      },
//  },
//},
},
}
apply, err := k.client.AutoscalingV2().HorizontalPodAutoscalers("mlu-showroom-test").
Create(context.Background(), autoscaler, apimetav1.CreateOptions{
TypeMeta: apimetav1.TypeMeta{
Kind:       "Pod",
APIVersion: "apps/v1",
},
FieldValidation: "Ignore",
})
if err != nil {
return nil, err
}
return apply, nil
}

我已与kubectl get核对，部署确实存在。

我尝试使用kubectl autoscale创建自动缩放器，它工作，我认为问题依赖于代码，但我不确定出了什么问题。

我找不到任何关于如何使用go-client创建水平自动缩放器的文档，上面的代码是通过引用本文档中yaml格式的字段创建的:https://kubernetes.io/docs/tasks/run-application/horizontal-pod-autoscale/

如果您以前使用过k8s go-client的HorizontalAutoScaler，请分享您的知识。

Answer 1

再次检查K8S版本后，我了解到有两个问题:

kubectl --kubeconfig=kubeconfig version
Client Version: version.Info{Major:"1", Minor:"19", GitVersion:"v1.19.7", GitCommit:"1dd5338295409edcfff11505e7bb246f0d325d15", GitTreeState:"clean", BuildDate:"2021-01-13T13:23:52Z", GoVersion:"go1.15.5", Compiler:"gc", Platform:"darwin/amd64"}
Server Version: version.Info{Major:"1", Minor:"22", GitVersion:"v1.22.5", GitCommit:"5c99e2ac2ff9a3c549d9ca665e7bc05a3e18f07e", GitTreeState:"clean", BuildDate:"2021-12-16T08:32:32Z", GoVersion:"go1.16.12", Compiler:"gc", Platform:"linux/amd64"}

• 我试图为内存和cpu创建一个自动缩放器，根据Kubernetes官方文档，这只能从kubernetes v1.23实现。
• 我为自动缩放器应用了错误的版本和名称。

经过一些修改后，工作代码如下所示

func (k *KubeClient) createAutoScaler(deploymentName string, namespace string) (*v12.HorizontalPodAutoscaler, error) {
autoscaler := &v12.HorizontalPodAutoscaler{
TypeMeta: apimetav1.TypeMeta{
Kind:       "Pod",
APIVersion: "autoscaling/v1",
},
ObjectMeta: apimetav1.ObjectMeta{
Name:      deploymentName,
Namespace: namespace,
},
Spec: v12.HorizontalPodAutoscalerSpec{
ScaleTargetRef: v12.CrossVersionObjectReference{
Kind:       "Deployment",
Name:       deploymentName,
APIVersion: "apps/v1",
},
MinReplicas:                    pointer.Int32(2),
MaxReplicas:                    5,
TargetCPUUtilizationPercentage: pointer.Int32(70),
},
}
apply, err := k.client.AutoscalingV1().HorizontalPodAutoscalers(namespace).
Create(context.Background(), autoscaler, apimetav1.CreateOptions{})
if err != nil {
return nil, err
}
return apply, nil
}