后端开发视角下的CRD之一

2020-12-02  本文已影响0人  wu_sphinx

CRD是什么?

Custom Resource Definitionsr的简称,它是对Kubernetes API 的扩展。打个并不严谨的比方,从所周知ServicePodDeployment等是k8s内置的资源类型,因为k8s使用golang开发,如果把Pod类比为golang中的int类型,那么CRD可以类比为golang中的interface: 抽象类型,这个比喻可能不那么恰当,只是为了方便个人理解。而关于CRD的产生过程,还有一段非常有坡的故事,可参考认文末张磊老师的的Kubernetes API 与 Operator:不为人知的开发者战争链接

如何编写自己的CRD?

对CRD有了初步了解之后,我们要如何写出自己想要的CRD呢?
就像我们写Http Server一样,有Gin等框架,写CRD同样也有对应的框架:kubebuilder。下面,我们一下一步来编辑自己的CRD

准备工作

准备工具

首先得自备一个k8s集群(笔者使用的是minikube),根据自己的开发环境下载kubebuilder工具

os=$(go env GOOS)
arch=$(go env GOARCH)

# download kubebuilder and extract it to tmp
curl -L https://go.kubebuilder.io/dl/2.3.1/${os}/${arch} | tar -xz -C /tmp/

# move to a long-term location and put it on your path
# (you'll need to set the KUBEBUILDER_ASSETS env var if you put it somewhere else)
sudo mv /tmp/kubebuilder_2.3.1_${os}_${arch} /usr/local/kubebuilder
export PATH=$PATH:/usr/local/kubebuilder/bin

项目初始化

mkdir $GOPATH/src/example
cd $GOPATH/src/example
kubebuilder init --domain my.domain

项目结构如下所示:

.
├── Dockerfile
├── Makefile
├── PROJECT
├── bin
│   └── manager
├── config
│   ├── certmanager
│   ├── default
│   ├── manager
│   ├── prometheus
│   ├── rbac
│   └── webhook
├── go.mod
├── go.sum
├── hack
│   └── boilerplate.go.txt
└── main.go

创建API

kubebuilder create api --group webapp --version v1 --kind Guestbook

到这一步,语义理解还是非常清楚的,就个人的理解:定义了一个RESTful的URI,类型、资源名称、Group等,很像我们平时写HTTP API的感觉,事实上,我们正在做的也确实在写一个API,目录结构如下:

.
├── Dockerfile
├── Makefile
├── PROJECT
├── api
│   └── v1
├── bin
│   └── manager
├── config
│   ├── certmanager
│   ├── crd
│   ├── default
│   ├── manager
│   ├── prometheus
│   ├── rbac
│   ├── samples
│   └── webhook
├── controllers
│   ├── guestbook_controller.go
│   └── suite_test.go
├── go.mod
├── go.sum
├── hack
│   └── boilerplate.go.txt
└── main.go

自定义类型:Guestbook

以下即是我们新创建的CRD:Guestbook的类型结构

// Guestbook is the Schema for the guestbooks API
type Guestbook struct {
    metav1.TypeMeta   `json:",inline"`
    metav1.ObjectMeta `json:"metadata,omitempty"`

    Spec   GuestbookSpec   `json:"spec,omitempty"`
    Status GuestbookStatus `json:"status,omitempty"`
}

我们来跟k8s内置类型Deployment对比一下

// Deployment enables declarative updates for Pods and ReplicaSets.
type Deployment struct {
    metav1.TypeMeta `json:",inline"`
    // Standard object metadata.
    // +optional
    metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

    // Specification of the desired behavior of the Deployment.
    // +optional
    Spec DeploymentSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`

    // Most recently observed status of the Deployment.
    // +optional
    Status DeploymentStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

类型结构几乎是一模一样的,可以看到metav1.TypeMetametav1.ObjectMeta是内嵌结构体,这是类型的一些公共定义,篇幅有限,就不在此处不展开了,Spec是需要注意的,前面我们定义了一个资源及期接口,那Spec可以认为是接口的入参了,Status: 顾名思义,资源的状态

入参校验

type GuestbookSpec struct {
    // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
    // Important: Run "make" to regenerate code after modifying this file

    // Foo is an example field of Guestbook. Edit Guestbook_types.go to remove/update
    // 设定参数Foo的取值范围,也就是做入参校验

    // +kubebuilder:validation:MaxLength=10
    // +kubebuilder:validation:MinLength=1
    Foo string `json:"foo,omitempty"`
}

此处只有一个参数Foo,我们通过注解的方式设定Foo的取值范围为[1,10]

安装CRD到k8s集群中

make install 

Guestbook这种资源类型注册到自己的k8s中以使外部系统能够访问到
部署一个Guestbook实例

kubectl apply -f config/samples/

这一步,以后端视角,就是调用POST接口新建一条"数据库"记录的,当然,k8s的数据库自然就是etcd了;如果我们将foo的值设为asdfgasdfg1,长度为11的字符串,再运行以上命令,会是什么结果呢?

The Guestbook "guestbook-sample" is invalid: spec.foo: Invalid value: "": spec.foo in body should be at most 10 chars long

可以看到入参校验生效了,

总结

至此,我们完成了一个CRD的最基本定义,以后端开发的视角而言,如果将CRD可以看作是一张表,这张表作为资源,这一节完成了对CRD这类资源的基本定义跟校验。

参考:

上一篇下一篇

猜你喜欢

热点阅读