您好,登錄后才能下訂單哦!
這篇文章主要介紹了自動生成代碼controller tool怎么使用的相關知識,內容詳細易懂,操作簡單快捷,具有一定借鑒價值,相信大家閱讀完這篇自動生成代碼controller tool怎么使用文章都會有所收獲,下面我們一起來看看吧。
controller-tools主要可以幫我們自動生成types.go所需要的內容以及自動幫我們生成crd。
同樣首先將其clone到本地:
$ git clone https://github.com/kubernetes-sigs/controller-tools.git
在項目的cmd目錄下,我們可以看到有controller-gen
、helpgen
、type-scaffold
三個工具。
其中type-scaffold
可以用來生成我們需要的types.go文件,controller-gen
可以生成zz_xxx.deepcopy.go
文件以及crd
文件。
我們使用go install
進行安裝:
$ cd controller-gen $ go install ./cmd/{controller-gen,type-scaffold}
安裝完成后我們可以去GOPATH下的bin目錄下查看。
接著我們就可以新建一個項目,來使用controller-tools提供的工具為我們自動生成代碼了。
$ 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
接下來我們就可以使用工具來生成我們所需要的代碼了,首先我們生成types.go
所需要的內容,由于type-scaffold
不支持導入文本,所以生成后我們需要復制到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"添加上就行。
當然自動生成只是一個模版,里面的具體細節還是需要我們自己去填寫,比如我們填充FooSpec
。
資源類型定義好了,那么如何能讓client-go識別我們的資源呢,這里就需要其注冊進去。我們可以在register.go中定義GV(Group Version),以及通過標簽指定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
中調用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{}) }
接下來就需要生成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
這時候我們查看項目結構:
. ├── 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
最后我們來進行驗證,首先創建一個cr:
apiVersion: example.com/v1 kind: Foo metadata: name: crd-test spec: name: test replicas: 2
將crd和cr添加到集群后,我們來編寫main.go文件來進行驗證:
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) } //======= // 輸出結果 test test2
關于“自動生成代碼controller tool怎么使用”這篇文章的內容就介紹到這里,感謝各位的閱讀!相信大家對“自動生成代碼controller tool怎么使用”知識都有一定的了解,大家如果還想學習更多知識,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。