Kubernetes 學習筆記 --- 訪問集群
我這里分享的是通過編程的方式去訪問k8s集群姿搜，之所以分享這種方式距帅，是因為我們可能有需要對k8s進行擴展，或者二次開發(fā)的需求，而我在學習時，苦于沒有簡單明了的文檔來幫助我學習,以至于走了很多彎路攻走，所以我把我的學習歷程記錄了下來饺著，分享給大家宾抓，有什么不對的地方，還請大家指正树叽。
前提
- 你需要有一個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 ：用于創(chuàng)建資源
- 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
動態(tài)客戶端 通常用于查詢自定義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
}
