Kubernetes 学习笔记 --- 访问集群

官方文档

我这里分享的是通过编程的方式去访问k8s集群，之所以分享这种方式，是因为我们可能有需要对k8s进行扩展，或者二次开发的需求，而我在学习时，苦于没有简单明了的文档来帮助我学习,以至于走了很多弯路，所以我把我的学习历程记录了下来，分享给大家，有什么不对的地方，还请大家指正。

前提

• 你需要有一个k8s集群
• 将k8s集群的admin.conf文件拷贝到你访问的地方
• 保护好你的admin.conf不要泄露-它拥有完全的k8s控制权限

如果你没有k8s集群，可以参考这篇文档，搭建一个自己的集群

获取客户端

k8s官方给我们提供几种获取k8s客户端方式，他们都被封装 client-go 这个package里

1: RESTClient

RESTClint是k8s官方提供的最基础的客户端，它将常见的 Kubernetes API 约定封装在一起。
它提供的Kubernetes API有：

• GetRateLimiter() flowcontrol.RateLimiter:用于获取限速器
• Verb(verb string) *Request ：用于设置请求的操作
• Post() *Request ：用于创建资源
• Put() *Request ：用于更新资源
• Patch(pt types.PatchType) *Request ：用于更新资源，与PUT有一定不同
• Get() *Request ：用于获取资源
• Delete() *Request ：用于删除资源
• APIVersion() schema.GroupVersion ：用于获取GroupVersion

package main

import (
    "context"
    "fmt"
    v1 "k8s.io/api/core/v1"
    v12 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/runtime/schema"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/kubernetes/scheme"
    "k8s.io/client-go/rest"
    "k8s.io/client-go/tools/clientcmd"
)

var nameSpace = "kube-system"
var podName = "coredns-64897985d-cmmk9"

func main() {
    // 获取k8s集群的admin.conf 并转换为*rest.Config
    config := getConfig()
    config.GroupVersion = &v1.SchemeGroupVersion
    config.NegotiatedSerializer = scheme.Codecs
    config.APIPath = "/api"
    // 获取RESTClient
    client, err := rest.RESTClientFor(config)
    if err != nil {
        panic(err)
    }
    // 获取POD
    var pod v1.Pod
    // 下面这行代码相当于在拼接URL 
    req := client.Get().Namespace(nameSpace).Resource("pods").Name(podName)
    fmt.Println(req.URL()) // https://ip:prot/api/v1/namespaces/kube-system/pods/coredns-64897985d-cmmk9
    err = req.Do(context.TODO()).Into(&pod)
    if err != nil {
        fmt.Println(err)
    } else {
        fmt.Println(pod.Name)
    }
}
func getConfig() *rest.Config {
    config, err := clientcmd.BuildConfigFromFlags("", "./admin.conf")
    if err != nil {
        panic(err)
    }
    return config
}

2: DynamicCli

动态客户端 通常用于查询自定义CRD或者本身服务里没有的资源,他解析出来的对象是一个map[string]interface{}

func dynamicCli() {
    resource := schema.GroupVersionResource{Group: "", Version: "v1", Resource: "pods"}
    config := getConfig()
    cli, err := dynamic.NewForConfig(config)
    if err != nil {
        panic(err)
    }
    cluster, err := cli.Resource(resource).List(context.TODO(), v12.ListOptions{})
    if err != nil {
        fmt.Println(err)
    } else {
        for _, item := range cluster.Items {
            fmt.Println(item.GetName())
        }
    }
}
func getConfig() *rest.Config {
    config, err := clientcmd.BuildConfigFromFlags("", "/Users/zhousong/admin.conf")
    if err != nil {
        panic(err)
    }
return config
}

3: ClientSet

ClientSet是k8s官方提供的官方资源的客户端，如，pods，nodes，role...等等
同时，我们自定义的CRD也可以生成client代码
ClientSet本质是在RESTClient上的一层针对特定资源的封装

//这段代码就是 clientSet.CoreV1().Pods 的源码 ，我们可以看出pod的client，其实就是RESTClient
type pods struct {
    client rest.Interface
    ns     string
}

// newPods returns a Pods
func newPods(c *CoreV1Client, namespace string) *pods {
    return &pods{
        client: c.RESTClient(),
        ns:     namespace,
    }
}

func clientCmd() {
    config := getConfig()
    clientSet, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err)
    }
    pod, err := clientSet.CoreV1().Pods(nameSpace).Get(context.TODO(), podName, v12.GetOptions{})
    if err != nil {
        fmt.Println(err)
    } else {
        fmt.Println(pod.Name)
    }
    pods, err := clientSet.CoreV1().Pods(nameSpace).List(context.TODO(), v12.ListOptions{})
    if err != nil {
        fmt.Println(err)
    } else {
        for _, item := range pods.Items {
            fmt.Println(item.Name)
        }
    }
    res, err := clientSet.ServerPreferredNamespacedResources()
    if err != nil {
        fmt.Println(err)
    } else {
        for _, re := range res {
            fmt.Println(re.GroupVersionKind().String(), re.GroupVersion)
        }
    }
}

func getConfig() *rest.Config {
    config, err := clientcmd.BuildConfigFromFlags("", "/Users/zhousong/admin.conf")
    if err != nil {
        panic(err)
    }
    return config
}