也可以参考官方的sample：https://github.com/kubernetes/sample-controller 1 官方文档了解下CRD https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/#create-a-customresourcedefinition 2 登录可以执行kubectl命令的机器，创建student.yaml文件 [root@localhost student]# kubectl apply -f student.yaml customresourcedefinition.apiextensions.k8s.io/students.stable.k8s.io created [root@localhost student]# kubectl get crd NAME CREATED AT crontabs.stable.example.com 2019-03-26T01:48:32Z students.stable.k8s.io 2019-04-12T02:42:08Z 3 通过模板student.yaml来实例一个Student对象，创建test1.yaml，同理实例test2.yaml [root@localhost student]# kubectl apply -f test1.yaml student.stable.k8s.io/test1 created 4 kubectl describe std test1 1 在samplecontroller目录下新建目录，并添加以下文件 [root@localhost studentcontroller]# tree pkg pkg ├── apis │ └── stable │ ├── register.go │ └── v1 │ ├── doc.go │ ├── register.go │ ├── types.go 主要是为代码生成工具准备好资源对象的声明和注册接口 2 下载依赖 go get -u k8s.io/apimachinery/pkg/apis/meta/v1 go get -u k8s.io/code-generator/... [root@localhost code-generator]# export GOPATH=/root/mygolang [root@localhost code-generator]# ./generate-groups.sh all "github.com/gfandada/samplecontroller/pkg/client" "github.com/gfandada/samplecontroller/pkg/apis" "stable:v1" Generating deepcopy funcs Generating clientset for stable:v1 at github.com/gfandada/samplecontroller/pkg/client/clientset Generating listers for stable:v1 at github.com/gfandada/samplecontroller/pkg/client/listers Generating informers for stable:v1 at github.com/gfandada/samplecontroller/pkg/client/informers [root@localhost samplecontroller]# tree pkg pkg ├── apis │ └── stable │ ├── register.go │ └── v1 │ ├── doc.go │ ├── register.go │ ├── types.go │ └── zz_generated.deepcopy.go ├── client │ ├── clientset │ │ └── versioned │ │ ├── clientset.go │ │ ├── doc.go │ │ ├── fake │ │ │ ├── clientset_generated.go │ │ │ ├── doc.go │ │ │ └── register.go │ │ ├── scheme │ │ │ ├── doc.go │ │ │ └── register.go │ │ └── typed │ │ └── stable │ │ └── v1 │ │ ├── doc.go │ │ ├── fake │ │ │ ├── doc.go │ │ │ ├── fake_stable_client.go │ │ │ └── fake_student.go │ │ ├── generated_expansion.go │ │ ├── stable_client.go │ │ └── student.go │ ├── informers │ │ └── externalversions │ │ ├── factory.go │ │ ├── generic.go │ │ ├── internalinterfaces │ │ │ └── factory_interfaces.go │ │ └── stable │ │ ├── interface.go │ │ └── v1 │ │ ├── interface.go │ │ └── student.go │ └── listers │ └── stable │ └── v1 │ ├── expansion_generated.go │ └── student.go 参考sample-controller工程，写的比较简单 [root@localhost samplecontroller]# ./samplecontroller 这是一个简易的自定制的k8s controller，用来演示k8s的终态运维的思想， https://github.com/gfandada/samplecontroller， gfandada@gmail.com Usage: samplecontroller [command] Available Commands: help Help about any command run run config=[kubeConfig的路径] Flags: --config string config file (default is $HOME/.samplecontroller.yaml) -h, --help help for samplecontroller -t, --toggle Help message for toggle Use "samplecontroller [command] --help" for more information about a command. [root@localhost samplecontroller]# ./samplecontroller run config=/root/.kube/config ERROR: logging before flag.Parse: I0415 15:02:28.619121 109337 samplecontroller.go:59] 创建事件广播器 ERROR: logging before flag.Parse: I0415 15:02:28.619246 109337 samplecontroller.go:76] 监听student的add/update/delete事件 ERROR: logging before flag.Parse: I0415 15:02:28.619264 109337 samplecontroller.go:102] 开始controller业务，开始一次缓存数据同步 ERROR: logging before flag.Parse: I0415 15:02:28.719511 109337 samplecontroller.go:107] 启动10个worker ERROR: logging before flag.Parse: I0415 15:02:28.719547 109337 samplecontroller.go:112] worker已经全部启动 ...... FIMXE ERROR: logging before flag.Parse多个flag库有些冲突，不影响本项目，正式开发可以考虑去掉cobra，打开flag.Parse() ........ kubectl apply -f test1.yaml kubectl describe std test1