Kubernetes的client-go库

Yuyy

发布于 2022-09-21 10:20:57

6480

发布于 2022-09-21 10:20:57

前言

client-go是一个调用kubernetes集群资源对象API的客户端，即通过client-go实现对kubernetes集群中资源对象增删改查等操作。大部分对kubernetes进行前置API封装的二次开发都通过client-go这个第三方包来实现。

RESTClient

最基础的，封装了指定资源URL访问Kubernetes API的姿势，相当于的底层基础结构，可以直接通过 RESTClient 提供的RESTful方法如Get()，Put()，Post()，Delete()和k8s进行交互。

获取k8s version

type K8sVersionResponse struct {
    GitVersion string
}

func (p *K8sProxy) getVersion(ctx context.Context) (string, error) {
    getVersionUrl := p.restConfig.Host + "/version"
    bytes, err := p.get(ctx, getVersionUrl)
    if err != nil {
        return "", err
    }
    k8sVersionResponse := K8sVersionResponse{}
    if err = jsoniter.Unmarshal(bytes, &k8sVersionResponse); err != nil {
        return "", errors.Wrap(err, "parse k8s version response json error")
    }
    return k8sVersionResponse.GitVersion, err
}

func (p *K8sProxy) get(ctx context.Context, url string) ([]byte, error) {
    req, err := http.NewRequest(http.MethodGet, url, nil)
    if err != nil {
        return nil, errors.Wrap(err, "create request error")
    }
    req = req.WithContext(ctx)
    resp, err := p.RestClient.Client.Do(req)
    if err != nil {
        return nil, errors.Wrap(err, "get request error")
    }
    defer resp.Body.Close()
    data, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return nil, errors.Wrap(err, "copy response body error")
    }
    return data, nil
}

响应值是json，最好是定义一个结构体对应，方便后期维护。而不是直接解析json字符串。
json对应的结构体不用定义json字符串里的全部字段，用到哪些就定义哪些。

Clientset

通过sdk里封装好的方法，对k8s里的一类资源进行操作。

ClientSet在RestClient的基础上封装了对Resouorce和Version的管理方法。

一个Resource可以理解为一个客户端，而ClientSet是多个客户端的集合

其操作资源对象时需要指定Group、指定Version，然后根据Resource获取，但是clientset不支持自定义crd（CustomResourceDefinition）。

更新configmap

configMap := v1.ConfigMap{
        ObjectMeta: metav1.ObjectMeta{
            Name: "xxx",
        },
        Data: map[string]string{
            "xxx.yaml": string(yaml),
        },
    }
_, err = clientset.CoreV1().ConfigMaps(xxx).Update(ctx, configMap, metav1.UpdateOptions{})

DynamicClient

DynamicClient是一种动态客户端它可以对任何资源进行restful操作包括crd自定义资源，不同于 clientset，dynamic client 返回的对象是一个 map[string]interface{}

利用DynamicClient更新自定义资源

resource := schema.GroupVersionResource{Group: "xxx", Version: "v1", Resource: "xxx"}
    // 先查询，有的情况下就更新，没有就创建
    xxx, err := k8sProxy.DynamicClient.Resource(resource).Get(ctx, xxx, metav1.GetOptions{})
    if err == nil {
        if err := unstructured.SetNestedField(xxx.Object, pop.Name, "spec", "pop"); err != nil {
            return err
        }
        _, err = k8sProxy.DynamicClient.Resource(resource).Update(ctx, xxx, metav1.UpdateOptions{})
    } else if k8sErrors.IsNotFound(err) {
        xxx := &unstructured.Unstructured{
            Object: map[string]interface{}{
                "apiVersion": "xxx/v1",
                "kind":       "xxx",
                "metadata": map[string]interface{}{
                    "name": xxx,
                },
                "spec": map[string]interface{}{
                    "pop":     pop.Name,
                },
            },
        }
        _, err = k8sProxy.DynamicClient.Resource(resource).Create(ctx, xxx, metav1.CreateOptions{})
    }
    return err