自動(dòng)生成代碼controller?tool的簡(jiǎn)單使用

更新時(shí)間：2022年05月13日 16:42:37 作者：李大鵝

這篇文章主要為大家介紹了自動(dòng)生成代碼controller?tool的簡(jiǎn)單使用示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

介紹

在上一篇code-generator簡(jiǎn)單介紹中重點(diǎn)介紹了如何使用code-generator來(lái)自動(dòng)生成代碼，通過(guò)自動(dòng)生成的代碼可以幫助我們像訪問(wèn)k8s內(nèi)置資源那樣來(lái)操作我們的CRD，其實(shí)就是幫助我們生成ClientSet、Informer、Lister等工具包。

但是我們需要自己定義types.go文件以及需要自己去編寫(xiě)crd文件。工作量其實(shí)也是很大的，那么有沒(méi)有工具像code-generator那樣幫助我們生成代碼呢？答案是肯定的，那就是接下來(lái)要介紹的controller-tools

controller-tools

controller-tools主要可以幫我們自動(dòng)生成types.go所需要的內(nèi)容以及自動(dòng)幫我們生成crd。

同樣首先將其clone到本地：

$ git clone https://github.com/kubernetes-sigs/controller-tools.git

在項(xiàng)目的cmd目錄下，我們可以看到有controller-gen、helpgen、type-scaffold三個(gè)工具。

其中type-scaffold可以用來(lái)生成我們需要的types.go文件，controller-gen可以生成zz_xxx.deepcopy.go文件以及crd文件。

我們使用go install進(jìn)行安裝：

$ cd controller-gen
$ go install ./cmd/{controller-gen,type-scaffold}

安裝完成后我們可以去GOPATH下的bin目錄下查看。

接著我們就可以新建一個(gè)項(xiàng)目，來(lái)使用controller-tools提供的工具為我們自動(dòng)生成代碼了。

$ mkdir controller-test && cd controller-test
$ go mod init controller-test
$ mkdir -p pkg/apis/example.com/v1
$ tree
.
├── go.mod
└── pkg
    └── apis
        └── example.com
            └── v1
4 directories, 1 file

接下來(lái)我們就可以使用工具來(lái)生成我們所需要的代碼了,首先我們生成types.go所需要的內(nèi)容，由于type-scaffold不支持導(dǎo)入文本，所以生成后我們需要復(fù)制到types.go文件中：

$ type-scaffold --kind Foo
// FooSpec defines the desired state of Foo
type FooSpec struct {
        // INSERT ADDITIONAL SPEC FIELDS -- desired state of cluster
}
// FooStatus defines the observed state of Foo.
// It should always be reconstructable from the state of the cluster and/or outside world.
type FooStatus struct {
        // INSERT ADDITIONAL STATUS FIELDS -- observed state of cluster
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// Foo is the Schema for the foos API
// +k8s:openapi-gen=true
type Foo struct {
        metav1.TypeMeta   `json:",inline"`
        metav1.ObjectMeta `json:"metadata,omitempty"`
        Spec   FooSpec   `json:"spec,omitempty"`
        Status FooStatus `json:"status,omitempty"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// FooList contains a list of Foo
type FooList struct {
        metav1.TypeMeta `json:",inline"`
        metav1.ListMeta `json:"metadata,omitempty"`
        Items           []Foo `json:"items"`
}

然后在types.go文件中將import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"添加上就行。

當(dāng)然自動(dòng)生成只是一個(gè)模版，里面的具體細(xì)節(jié)還是需要我們自己去填寫(xiě)，比如我們填充FooSpec。

資源類(lèi)型定義好了，那么如何能讓client-go識(shí)別我們的資源呢，這里就需要其注冊(cè)進(jìn)去。我們可以在register.go中定義GV(Group Version),以及通過(guò)標(biāo)簽指定groupName。

// register.go
// +groupName=example.com
package v1
import (
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/runtime/schema"
	"k8s.io/apimachinery/pkg/runtime/serializer"
)
var (
	Scheme       = runtime.NewScheme()
	GroupVersion = schema.GroupVersion{
		Group:   "example.com",
		Version: "v1",
	}
	Codec = serializer.NewCodecFactory(Scheme)
)

在types.go中調(diào)用Scheme.AddKnownTypes方法即可：

// types.go
package v1
import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
// FooSpec defines the desired state of Foo
type FooSpec struct {
	// INSERT ADDITIONAL SPEC FIELDS -- desired state of cluster
	Name     string `json:"name"`
	Replicas int32  `json:"replicas"`
}
// FooStatus defines the observed state of Foo.
// It should always be reconstructable from the state of the cluster and/or outside world.
type FooStatus struct {
	// INSERT ADDITIONAL STATUS FIELDS -- observed state of cluster
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// Foo is the Schema for the foos API
// +k8s:openapi-gen=true
type Foo struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec   FooSpec   `json:"spec,omitempty"`
	Status FooStatus `json:"status,omitempty"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// FooList contains a list of Foo
type FooList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Foo `json:"items"`
}
func init() {
	Scheme.AddKnownTypes(GroupVersion, &Foo{}, &FooList{})
}

接下來(lái)就需要生成deepcopy.go文件了：

$ controller-gen object paths=./pkg/apis/example.com/v1/types.go

同樣，我們使用controller-gen生成crd:

$ mkdir config
$ go mod tidy
$ controller-gen crd paths=./... output:crd:dir=config/crd

這時(shí)候我們查看項(xiàng)目結(jié)構(gòu)：

.
├── config
│?? └── crd
│??     └── example.com_foos.yaml
├── go.mod
├── go.sum
└── pkg
    └── apis
        └── example.com
            └── v1
                ├── register.go
                ├── types.go
                └── zz_generated.deepcopy.go
6 directories, 6 files

最后我們來(lái)進(jìn)行驗(yàn)證，首先創(chuàng)建一個(gè)cr：

apiVersion: example.com/v1
kind: Foo
metadata:
  name: crd-test
spec:
  name: test
  replicas: 2

將crd和cr添加到集群后，我們來(lái)編寫(xiě)main.go文件來(lái)進(jìn)行驗(yàn)證：

package main
import (
	"context"
	v1 "controller-test/pkg/apis/example.com/v1"
	"fmt"
	"k8s.io/client-go/rest"
	"k8s.io/client-go/tools/clientcmd"
	"log"
)
func main() {
	config, err := clientcmd.BuildConfigFromFlags("", clientcmd.RecommendedHomeFile)
	if err != nil {
		log.Fatalln(err)
	}
	// 這邊需要使用原始的 RESTClient
	config.APIPath = "/apis/"
	config.NegotiatedSerializer = v1.Codec
	config.GroupVersion = &v1.GroupVersion
	client, err := rest.RESTClientFor(config)
	if err != nil {
		log.Fatalln(err)
	}
	foo := &v1.Foo{}
	err = client.Get().Namespace("default").Resource("foos").Name("crd-test").Do(context.TODO()).Into(foo)
	if err != nil {
		log.Fatalln(err)
	}
	newObj := foo.DeepCopy()
	newObj.Spec.Name = "test2"
	fmt.Println(foo.Spec.Name)
	fmt.Println(newObj.Spec.Name)
}
//=======
// 輸出結(jié)果
test
test2

以上就是自動(dòng)生成代碼controller tool的簡(jiǎn)單使用的詳細(xì)內(nèi)容，更多關(guān)于自動(dòng)生成代碼controller tool的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: