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
}
