歡迎訪問我的GitHub

https://github.com/zq2599/blog_demos

內容：所有原創文章分類彙總及配套原始碼，涉及Java、Docker、Kubernetes、DevOPS等；

關於DiscoveryClient

  • 本文是《client-go實戰》系列的第五篇，主角是最後一種客戶端：DiscoveryClient，咱們之前學習的Clientset和dynamicClient都是面向資源物件的（例如建立deployment例項、檢視pod例項），而DiscoveryClient則不同，它聚焦的是資源，例如檢視當前kubernetes有哪些Group、Version、Resource，下面是DiscoveryClient資料結構的欄位和關聯方法，再次看到了熟悉的restClient欄位，還有一眾方法皆是與Group、Version、Resource有關：

  • 從上圖可見，DiscoveryClient資料結構有兩個欄位：restClient和LegacyPrefix，這個LegacyPrefix是啥呢？去看看新建DiscoveryClient例項的方法，如下圖紅框，原來是個固定字串/api，看起來像是url中的一部分：

  • 挑一個DiscoveryClient的關聯方法看看，如下圖紅框，果然，LegacyPrefix就是url中的一部分：

  • 相比其他幾個客戶端，DiscoveryClient要更簡單一些，乾脆直接實戰吧！

需求確認

  • 本次實戰的需求很簡單：從kubernetes查詢所有的Group、Version、Resource資訊，在控制檯打印出來；

原始碼下載

名稱 連結 備註
專案主頁 https://github.com/zq2599/blog_demos 該專案在GitHub上的主頁
git倉庫地址(https) https://github.com/zq2599/blog_demos.git 該專案原始碼的倉庫地址，https協議
git倉庫地址(ssh) [email protected]:zq2599/blog_demos.git 該專案原始碼的倉庫地址，ssh協議
  • 這個git專案中有多個資料夾，client-go相關的應用在client-go-tutorials資料夾下，如下圖紅框所示：

  • client-go-tutorials資料夾下有多個子資料夾，本篇對應的原始碼在discoveryclientdemo目錄下，如下圖紅框所示：

編碼

  • 新建資料夾discoveryclientdemo，在裡面執行以下命令，新建module：
go mod init discoveryclientdemo
  • 新增k8s.io/api和k8s.io/client-go這兩個依賴，注意版本要匹配kubernetes環境：
go get k8s.io/[email protected]

go get k8s.io/[email protected]
  • 新建main.go，內容如下，內部已有詳細註釋，要重點關注的是ServerGroupsAndResources方法的第二個返回值，它的資料結構中有切片，切片的每個元素裡面又有切片，這才是每個資源的資訊：
package main

import (

	"flag"

	"fmt"

	"k8s.io/apimachinery/pkg/runtime/schema"

	"k8s.io/client-go/discovery"

	"k8s.io/client-go/tools/clientcmd"

	"k8s.io/client-go/util/homedir"

	"path/filepath"

)

func main() {

	var kubeconfig *string

	// home是家目錄，如果能取得家目錄的值，就可以用來做預設值

	if home:=homedir.HomeDir(); home != "" {

		// 如果輸入了kubeconfig引數，該引數的值就是kubeconfig檔案的絕對路徑，

		// 如果沒有輸入kubeconfig引數，就用預設路徑~/.kube/config

		kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")

	} else {

		// 如果取不到當前使用者的家目錄，就沒辦法設定kubeconfig的預設目錄了，只能從入參中取

		kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")

	}

	flag.Parse()

	// 從本機載入kubeconfig配置檔案，因此第一個引數為空字串

	config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)

	// kubeconfig載入失敗就直接退出了

	if err != nil {

		panic(err.Error())

	}

	// 新建discoveryClient例項

	discoveryClient, err := discovery.NewDiscoveryClientForConfig(config)

	if err != nil {

		panic(err.Error())

	}

	// 獲取所有分組和資源資料

	APIGroup, APIResourceListSlice, err := discoveryClient.ServerGroupsAndResources()

	if err != nil {

		panic(err.Error())

	}

	// 先看Group資訊

	fmt.Printf("APIGroup :\n\n %v\n\n\n\n",APIGroup)

	// APIResourceListSlice是個切片，裡面的每個元素代表一個GroupVersion及其資源

	for _, singleAPIResourceList := range APIResourceListSlice {

		// GroupVersion是個字串，例如"apps/v1"

		groupVerionStr := singleAPIResourceList.GroupVersion

		// ParseGroupVersion方法將字串轉成資料結構

		gv, err := schema.ParseGroupVersion(groupVerionStr)

		if err != nil {

			panic(err.Error())

		}

		fmt.Println("*****************************************************************")

		fmt.Printf("GV string [%v]\nGV struct [%#v]\nresources :\n\n", groupVerionStr, gv)

		// APIResources欄位是個切片，裡面是當前GroupVersion下的所有資源

		for _, singleAPIResource := range singleAPIResourceList.APIResources {

			fmt.Printf("%v\n", singleAPIResource.Name)

		}

	}

}
  • 執行go run main.go，擷取部分執行結果如下，所有資源都被打印出來了：
...

*****************************************************************

GV string [discovery.k8s.io/v1beta1]

GV struct [schema.GroupVersion{Group:"discovery.k8s.io", Version:"v1beta1"}]

resources :

endpointslices

*****************************************************************

GV string [flowcontrol.apiserver.k8s.io/v1beta1]

GV struct [schema.GroupVersion{Group:"flowcontrol.apiserver.k8s.io", Version:"v1beta1"}]

resources :

flowschemas

flowschemas/status

prioritylevelconfigurations

prioritylevelconfigurations/status
  • 以上就是DiscoveryClient的基本用法，您是否覺得這樣的實戰太easy了，那咱們就來個延伸閱讀，看看DiscoveryClient的周邊場景；

kubectl中如何使用DiscoveryClient

  • kubectl api-versions命令，大家應該不陌生吧，可以返回當前kubernetes環境的所有Group+Version的組合，如下：
zhaoqin@zhaoqindeMBP-2 discoveryclientdemo % kubectl api-versions

admissionregistration.k8s.io/v1

admissionregistration.k8s.io/v1beta1

apiextensions.k8s.io/v1

apiextensions.k8s.io/v1beta1

apiregistration.k8s.io/v1

apiregistration.k8s.io/v1beta1

apps/v1

authentication.k8s.io/v1

...
  • 通過檢視kubectl原始碼可見，上述命令的背後就是使用了DiscoveryClient來實現的，如下圖紅框所示：

  • 還有一處沒有明確：上圖紅框2中的o.discoveryClient究竟是不是DiscoveryClient呢？雖然名字很像，但還是瞅一眼才放心，結果這一瞅有了新發現，如下所示，discoveryClient的資料結構是CachedDiscoveryInterface：
type APIVersionsOptions struct {

	discoveryClient discovery.CachedDiscoveryInterface

	genericclioptions.IOStreams

}

  • 從名稱CachedDiscoveryInterface來看，kubectl對GVR資料是做了本地快取的，想想也是，GVR不經常變化，沒必要每次都去API Server拉取，關於快取的細節請參考：staging/src/k8s.io/client-go/discovery/cached/disk/cached_discovery.go ，這裡就不展開了；

  • 至此，client-go的四種客戶端工具實戰以及相關原始碼的淺層次分析就全部完成了，在您做client-go開發的時候，希望這些內容能給您提供一些參考；

你不孤單，欣宸原創一路相伴

  1. Java系列
  2. Spring系列
  3. Docker系列
  4. kubernetes系列
  5. 資料庫+中介軟體系列
  6. DevOps系列

歡迎關注公眾號：程式設計師欣宸

微信搜尋「程式設計師欣宸」，我是欣宸，期待與您一同暢遊Java世界...

https://github.com/zq2599/blog_demos