资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/kubernetes自定义资源对象高级功能

kubernetes自定义资源对象高级功能

陈江龙 / 2374人阅读

摘要：可以通过验证自定义对象是否符合标准。此功能可用于及以上版本自定义资源。状态和规范节分别由自定义资源内的和表示。对子资源的请求采用自定义资源对象，并忽略除状态节之外的任何更改。该对象作为有效负载发送。

kubernetes自定义资源对象高级功能 
</>复制代码 
  1. 本文首发于微信公众号“我的小碗汤”，扫码文末二维码即可关注，欢迎一起交流！

kubernetes自定义资源对象再极大程度提高了API Server的可扩展性，让企业能够根据业务需求通过CRD编写controller或者operator来实现生产中各种特殊场景。随着k8s的版本升级，CRD的功能也越来越完善，下面对其中几点进行说明。

以下验证kubernetes版本为1.13.2，docker版本：18.09.5

Validation（验证）

在项目中用自定义资源对象时，如果创建自定义资源时某些字段不符合要求，会导致监听该资源对象的controller或者operator出现异常，解析结构体报错，所以Validation这个功能非常实用，在创建时就进行校验，减少后面的排错和异常处理的麻烦。

可以通过 OpenAPI v3 schema验证自定义对象是否符合标准 。此外，以下限制适用于 schema：

字段default、nullable、discriminator、readOnly、writeOnly、xml、 deprecated 和 $ref 不能设置。

该字段 uniqueItems 不能设置为 true。

该字段 additionalProperties 不能设置为 false。

可以使用 kube-apiserverCustomResourceValidation 上的功能门（feature gate）禁用此功能：

</>复制代码 
  1. --feature-gates=CustomResourceValidation=false

从以下特性门参数说明地址，可以看到Validation功能在k8s 1.8版本就已经有了，但是CustomResourceValidation特性门是默认false，1.9Beta之后版本默认为true

https://kubernetes.io/docs/re...

以下示例将大概对该功能进行应用和说明，在以下示例中，CustomResourceDefinition 对自定义对象应用以下验证：

spec.replicas 为必填项，类型为integer，值为大于等于0小于50的偶数（2的倍数）；

spec.repository 为必填项；

spec.version为必填项；

spec.pause为boolean类型；

spec.updateStrategy为object类型，该object中有type、pipeline、assignStrategies属性；

spec.updateStrategy.type为string类型，而且只能为"AssignReceive", "AutoReceive"两个枚举值；

spec.updateStrategy.pipeline为string类型，而且为正整数的字符串，符合正则表达式^([1-9][0-9]*){1,3}$;

spec.updateStrategy.assignStrategies为array类型，其元素为object类型（包含slots和fromReplicas属性）；

spec.updateStrategy.assignStrategies.slots为1-16384的正整数；

spec.updateStrategy.assignStrategies.fromReplicas为字符串，符合正则表达式^[a-z0-9,]{3,}$，即至少匹配3位a-z或者0-9或者逗号的字符串；

spec.pod为array类型，其元素为object类型（包含configmap、monitorImage、initImage、middlewareImage字段）；

spec.pod.configmap、spec.pod.monitorImage、spec.pod.initImage 、spec.pod.middlewareImage为string类型；且用required指定configmap、initImage、middlewareImage字段为必填项。

将以下内容保存到 redis-cluster-crd.yaml：

</>复制代码 
  1. apiVersion: apiextensions.k8s.io/v1beta1
  2. kind: CustomResourceDefinition
  3. metadata:
  4.   name: redisclusters.redis.middleware.hc.cn
  5. spec:
  6.   group: redis.middleware.hc.cn
  7.   versions:
  8.     - name: v1alpha1
  9.       # Each version can be enabled/disabled by Served flag.
  10.       served: true
  11.       # One and only one version must be marked as the storage version.
  12.       storage: true
  13.   scope: Namespaced
  14.   names:
  15.     kind: RedisCluster
  16.     singular: rediscluster
  17.     listKind: RedisClusterList
  18.     plural: redisclusters
  19.     shortNames:
  20.     - rec
  21.     # 执行kubectl get all时会查到pod、service、该crd等属于all categories的资源对象
  22.     categories:
  23.     - all
  24.   validation:
  25.     # openAPIV3Schema 适用于验证自定义对象的 schema。
  26.     openAPIV3Schema:
  27.       properties:
  28.         spec:
  29.           required: ["replicas", "repository", "version"]
  30.           properties:
  31.             pause:
  32.               type: boolean
  33.             replicas:
  34.               type: integer
  35.               minimum: 0
  36.               maximum: 50
  37.               # 偶数
  38.               multipleOf: 2
  39.             updateStrategy:
  40.               type: object
  41.               properties:
  42.                 type:
  43.                   type: string
  44.                   # 枚举
  45.                   enum: ["AssignReceive", "AutoReceive"]
  46.                 pipeline:
  47.                   type: string
  48.                   pattern: "^([1-9][0-9]*){1,3}$"
  49.                 assignStrategies:
  50.                   type: array
  51.                   items:
  52.                     type: object
  53.                     properties:
  54.                       slots:
  55.                         type: integer
  56.                         minimum: 1
  57.                         maximum: 16384
  58.                       fromReplicas:
  59.                         type: string
  60.                         # 至少匹配3位,a-z或者0-9或者,
  61.                         pattern: "^[a-z0-9,]{3,}$"
  62.             pod:
  63.               type: array
  64.               items:
  65.                 type: object
  66.                 required: ["configmap", "middlewareImage", "initImage"]
  67.                 properties:
  68.                   configmap:
  69.                     type: string
  70.                   monitorImage:
  71.                     type: string
  72.                   initImage:
  73.                     type: string
  74.                   middlewareImage:
  75.                     type: string

创建它：

</>复制代码 
  1. kubectl create -f redis-cluster-crd.yaml

默认不加validation时，在创建自定义资源对象时，不会校验，有些字段没有了（如spec.replicas）都可以正常被创建，为了减少排错的难度和operator、controller的麻烦的检验，所以在创建自定义资源定义时，就把validation加上。以上的检验应该覆盖到了常见的检验场景，其他场景可以自己摸索。具体还可以参考kubernetes源码，1.13.2版本kubernetes源码位于types.go第327行CustomResourceValidation结构体：

</>复制代码 
  1. $GOPATH/src/k8s.io/kubernetes/staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/types.go

将以下YAML保存到redis-cluster-cr.yaml：

</>复制代码 
  1. apiVersion: redis.middleware.hc.cn/v1alpha1
  2. kind: RedisCluster
  3. metadata: 
  4.   name: example000-redis-cluster
  5.   namespace: kube-system
  6. spec:
  7.   # 代表redis集群的个数
  8.   replicas: 3
  9.   # 代表是否进入维修状态
  10.   pause: true
  11.   repository: library/redis
  12.   # 镜像版本，便于后续多版本特化支持
  13.   version: 3.2.6
  14.   #redis集群升级策略
  15.   updateStrategy:
  16.     # 升级类型为AutoReceive（自动分配,不用AssignStrategies）, AssignReceive（指定值分配，需要用AssignStrategies）
  17.     type: AssignReceive1
  18.     pipeline: "100a"
  19.     assignStrategies:
  20.        - 
  21.         slots: 0
  22.         fromReplicas: nodeId1
  23.        - 
  24.         # 从nodeId3,nodeId4一共分配1000个卡槽
  25.         slots: 1000 
  26.         # 多个nodeId用逗号分隔
  27.         fromReplicas: nodeId3,nodeId4
  28.   # redis 实例配置详情
  29.   pod:
  30.     # 配置文件模板名
  31.   - configmap: example000-redis-cluster-config
  32.     # 监控镜像
  33.     monitorImage: redis-exporter:v1
  34.     # 初始化镜像
  35.     #initImage: redis-init:v1
  36.     # 中间件容器镜像
  37.     middlewareImage: redis-trib:3.2.6

并创建它：

</>复制代码 
  1. kubectl create -f redis-cluster-cr.yaml

会发现报以下错误：

</>复制代码 
  1. # kubectl apply -f redis-cluster-cr.yaml 
  2. The RedisCluster "example000-redis-cluster" is invalid: []: Invalid value: map[string]interface {}{"apiVersion":"redis.middleware.hc.cn/v1alpha1", "kind":"RedisCluster", "metadata":map[string]interface {}{"namespace":"kube-system", "uid":"b0946031-766b-11e9-b457-000c295db389", "resourceVersion":"44231", "generation":19, "creationTimestamp":"2019-05-14T17:14:10Z", "annotations":map[string]interface {}{"kubectl.kubernetes.io/last-applied-configuration":"{"apiVersion":"redis.middleware.hc.cn/v1alpha1","kind":"RedisCluster","metadata":{"annotations":{},"name":"example000-redis-cluster","namespace":"kube-system"},"spec":{"pause":true,"pod":[{"configmap":"example000-redis-cluster-config","middlewareImage":"redis-trib:3.2.6","monitorImage":"redis-exporter:v1"}],"replicas":3,"repository":"library/redis","updateStrategy":{"assignStrategies":[{"fromReplicas":"nodeId1","slots":0},{"fromReplicas":"nodeId3,nodeId4","slots":1000}],"pipeline":"100a","type":"AssignReceive1"},"version":"3.2.6"}}
  3. "}, "name":"example000-redis-cluster"}, "spec":map[string]interface {}{"version":"3.2.6", "pause":true, "pod":[]interface {}{map[string]interface {}{"middlewareImage":"redis-trib:3.2.6", "monitorImage":"redis-exporter:v1", "configmap":"example000-redis-cluster-config"}}, "replicas":3, "repository":"library/redis", "updateStrategy":map[string]interface {}{"assignStrategies":[]interface {}{map[string]interface {}{"fromReplicas":"nodeId1", "slots":0}, map[string]interface {}{"fromReplicas":"nodeId3,nodeId4", "slots":1000}}, "pipeline":"100a", "type":"AssignReceive1"}}}: validation failure list:
  4. spec.updateStrategy.assignStrategies.fromReplicas in body should match "^[a-z0-9,]{3,}$"
  5. spec.updateStrategy.assignStrategies.slots in body should be greater than or equal to 1
  6. spec.updateStrategy.pipeline in body should match "^([1-9][0-9]*){1,3}$"
  7. spec.updateStrategy.type in body should be one of [AssignReceive AutoReceive]
  8. spec.pod.initImage in body is required
  9. spec.replicas in body should be a multiple of 2

如果所有字段都符合校验逻辑，才可以创建对象。

将以下 YAML 保存到 redis-cluster-cr.yaml：

</>复制代码 
  1. apiVersion: redis.middleware.hc.cn/v1alpha1
  2. kind: RedisCluster
  3. metadata: 
  4.   name: example000-redis-cluster
  5.   namespace: kube-system
  6. spec:
  7.   # 代表redis集群的个数
  8.   replicas: 6
  9.   # 代表是否进入维修状态
  10.   pause: true
  11.   repository: library/redis
  12.   # 镜像版本，便于后续多版本特化支持
  13.   version: 3.2.6
  14.   #redis集群升级策略
  15.   updateStrategy:
  16.     # 升级类型为AutoReceive（自动分配,不用AssignStrategies）, AssignReceive（指定值分配，需要用AssignStrategies）
  17.     type: AssignReceive
  18.     pipeline: "100"
  19.     assignStrategies:
  20.        - 
  21.         slots: 1
  22.         fromReplicas: all
  23.        - 
  24.         # 从nodeId3,nodeId4一共分配1000个卡槽
  25.         slots: 1000 
  26.         # 多个nodeId用逗号分隔
  27.         fromReplicas: node1,node2
  28.   # redis 实例配置详情
  29.   pod:
  30.     # 配置文件模板名
  31.   - configmap: example000-redis-cluster-config
  32.     # 监控镜像
  33.     monitorImage: redis-exporter:v1
  34.     # 初始化镜像
  35.     initImage: redis-init:v1
  36.     # 中间件容器镜像
  37.     middlewareImage: redis-trib:3.2.6

并创建它，发现才可以创建：

</>复制代码 
  1. # kubectl apply -f redis-cluster-cr.yaml 
  2. rediscluster.redis.middleware.hc.cn/example000-redis-cluster configured
Category（分类）

类别是自定义资源所属的分组资源的列表（例如 all）。您可以使用 kubectl get 列出属于该类别的资源。此功能可用于 v1.10 及以上k8s版本自定义资源。

以下示例添加 all CustomResourceDefinition 中的类别列表，并说明如何使用 kubectl get all 输出自定义资源 。

将以下 内容保存到 redis-cluster-crd.yaml中执行kubectl apply -f redis-cluster-crd.yaml：

</>复制代码 
  1. apiVersion: apiextensions.k8s.io/v1beta1
  2. kind: CustomResourceDefinition
  3. metadata:
  4.   name: redisclusters.redis.middleware.hc.cn
  5. spec:
  6.   group: redis.middleware.hc.cn
  7.   versions:
  8.     - name: v1alpha1
  9.       # Each version can be enabled/disabled by Served flag.
  10.       served: true
  11.       # One and only one version must be marked as the storage version.
  12.       storage: true
  13.   scope: Namespaced
  14.   names:
  15.     kind: RedisCluster
  16.     singular: rediscluster
  17.     listKind: RedisClusterList
  18.     plural: redisclusters
  19.     shortNames:
  20.     - rec
  21.     # 执行kubectl get all时会查到pod、service、该crd等属于all categories的资源对象
  22.     categories:
  23.     - all

将以下内容保存到redis-cluster-cr.yaml中执行kubectl apply -f redis-cluster-cr.yaml：

</>复制代码 
  1. apiVersion: redis.middleware.hc.cn/v1alpha1
  2. kind: RedisCluster
  3. metadata: 
  4.   name: example000-redis-cluster
  5.   namespace: kube-system
  6. spec:
  7.   # 代表redis集群的个数
  8.   replicas: 6
  9.   # 代表是否进入维修状态
  10.   pause: true
  11.   repository: library/redis
  12.   # 镜像版本，便于后续多版本特化支持
  13.   version: 3.2.6
  14.   #redis集群升级策略
  15.   updateStrategy:
  16.     # 升级类型为AutoReceive（自动分配,不用AssignStrategies）, AssignReceive（指定值分配，需要用AssignStrategies）
  17.     type: AssignReceive
  18.     pipeline: "100"
  19.     assignStrategies:
  20.        - 
  21.         slots: 2000
  22.         fromReplicas: nodeId1
  23.        - 
  24.         # 从nodeId3,nodeId4一共分配1000个卡槽
  25.         slots: 1000 
  26.         # 多个nodeId用逗号分隔
  27.         fromReplicas: nodeId3,nodeId4
  28.   # redis 实例配置详情
  29.   pod:
  30.     # 配置文件模板名
  31.   - configmap: example000-redis-cluster-config
  32.     # 监控镜像
  33.     monitorImage: redis-exporter:v1
  34.     # 初始化镜像
  35.     initImage: redis-init:v1
  36.     # 中间件容器镜像
  37.     middlewareImage: redis-trib:3.2.6

执行kubectl get all -nkube-system时会查到pod、service、该crd等属于all categories的资源对象。（这个可能得等几分钟才能生效）

子资源 status子资源

启用状态子资源后，将公开自定义资源的子资源 /status。

状态和规范节分别由自定义资源内的 .status 和 .spec JSONPath 表示。

PUT /status 对子资源的请求采用自定义资源对象，并忽略除状态节之外的任何更改。

PUT /status 对子资源的请求仅验证自定义资源的状态节。

PUT/ POST/ PATCH 请求自定义资源忽略更改状态节。

对 spec 节的任何更改都会增加 .metadata.generation 的值。

在code-generator生成代码时会生成，如下方法：

</>复制代码 
  1. // RedisClusterInterface has methods to work with RedisCluster resources.
  2. type RedisClusterInterface interface {
  3.     Create(*v1alpha1.RedisCluster) (*v1alpha1.RedisCluster, error)
  4.     Update(*v1alpha1.RedisCluster) (*v1alpha1.RedisCluster, error)
  5.     UpdateStatus(*v1alpha1.RedisCluster) (*v1alpha1.RedisCluster, error)
  6.     ......
  7. }
scale子资源

启用 scale 子资源后，将公开自定义资源的子资源 /scale。该 autoscaling/v1.Scale 对象作为有效负载发送 /scale。

要启用 scale 子资源，CustomResourceDefinition 中需要定义以下值。

SpecReplicasPath 在与之对应的自定义资源中定义 JSONPath Scale.Spec.Replicas。这是一个必需的值。.spec 只允许使用带点符号的 JSONPaths 。如果 SpecReplicasPath 自定义资源中没有值，则 /scale 子资源将在GET上返回错误。

StatusReplicasPath 在与之对应的自定义资源中定义 JSONPath Scale.Status.Replicas。这是一个必需的值。.stutus 只允许使用带点符号的 JSONPaths 。如果 StatusReplicasPath 自定义资源中没有值，则子资源 /scale 中的状态副本值将默认为 0。

LabelSelectorPath在与之对应的自定义资源中定义 JSONPath Scale.Status.Selector。这是一个可选值。必须将其设置为与 HPA 一起使用。.status 只允许使用带点符号的 JSONPaths 。如果 LabelSelectorPath 自定义资源中没有值，则子资源 /scale 中的状态选择器值将默认为空字符串。

在以下示例中，启用了status 和 scale 子资源。

将以下内容保存到redis-cluster-crd.yaml并创建 kubectl apply -f redis-cluster-crd.yaml：

</>复制代码 
  1. apiVersion: apiextensions.k8s.io/v1beta1
  2. kind: CustomResourceDefinition
  3. metadata:
  4.   name: redisclusters.redis.middleware.hc.cn
  5. spec:
  6.   group: redis.middleware.hc.cn
  7.   versions:
  8.     - name: v1alpha1
  9.       # Each version can be enabled/disabled by Served flag.
  10.       served: true
  11.       # One and only one version must be marked as the storage version.
  12.       storage: true
  13.   scope: Namespaced
  14.   names:
  15.     kind: RedisCluster
  16.     singular: rediscluster
  17.     listKind: RedisClusterList
  18.     plural: redisclusters
  19.     shortNames:
  20.     - rec
  21.     # 执行kubectl get all时会查到pod、service、该crd等属于all categories的资源对象
  22.     categories:
  23.     - all
  24.   subresources:
  25.     # status enables the status subresource.
  26.     status: {}
  27.     scale:
  28.       # specReplicasPath defines the JSONPath inside of a custom resource that corresponds to Scale.Spec.Replicas.
  29.       specReplicasPath: .spec.replicas
  30.       # statusReplicasPath defines the JSONPath inside of a custom resource that corresponds to Scale.Status.Replicas.
  31.       statusReplicasPath: .status.replicas
  32.       # labelSelectorPath defines the JSONPath inside of a custom resource that corresponds to Scale.Status.Selector.
  33.       labelSelectorPath: .status.labelSelector

创建 CustomResourceDefinition 对象后，您可以创建自定义对象。

如果您将以下 YAML 保存到 redis-cluster-cr.yaml：

</>复制代码 
  1. apiVersion: redis.middleware.hc.cn/v1alpha1
  2. kind: RedisCluster
  3. metadata: 
  4.   name: example000-redis-cluster
  5.   namespace: kube-system
  6. spec:
  7.   # 代表redis集群的个数
  8.   replicas: 6
  9.   # 代表是否进入维修状态
  10.   pause: true
  11.   repository: library/redis
  12.   # 镜像版本，便于后续多版本特化支持
  13.   version: 3.2.6
  14.   #redis集群升级策略
  15.   updateStrategy:
  16.     # 升级类型为AutoReceive（自动分配,不用AssignStrategies）, AssignReceive（指定值分配，需要用AssignStrategies）
  17.     type: AssignReceive
  18.     pipeline: "100"
  19.     assignStrategies:
  20.        - 
  21.         slots: 2000
  22.         fromReplicas: nodeId1
  23.        - 
  24.         # 从nodeId3,nodeId4一共分配1000个卡槽
  25.         slots: 1000 
  26.         # 多个nodeId用逗号分隔
  27.         fromReplicas: nodeId3,nodeId4
  28.   # redis 实例配置详情
  29.   pod:
  30.     # 配置文件模板名
  31.   - configmap: example000-redis-cluster-config
  32.     # 监控镜像
  33.     monitorImage: redis-exporter:v1
  34.     # 初始化镜像
  35.     initImage: redis-init:v1
  36.     # 中间件容器镜像
  37.     middlewareImage: redis-trib:3.2.6

并创建它：

</>复制代码 
  1. kubectl create -f redis-cluster-cr.yaml

然后在以下位置创建新的命名空间 RESTful API 端点：

</>复制代码 
  1. /apis/redis.middleware.hc.cn/v1alpha1/namespaces/kube-system/redisclusters/example000-redis-cluster/status

和

</>复制代码 
  1. /apis/redis.middleware.hc.cn/v1alpha1/namespaces/kube-system/redisclusters/example000-redis-cluster/scale

可以使用该 kubectl scale 命令缩放自定义资源。例如，以上创建的自定义资源的的 .spec.replicas 设置为 10：

</>复制代码 
  1. # kubectl get rec --all-namespaces
  2. NAMESPACE     NAME                       DESIRED   PAUSE   AGE
  3. kube-system   example000-redis-cluster   6         true    10h
  4. # kubectl scale --replicas=10 rec/example000-redis-cluster -nkube-system
  5. rediscluster.redis.middleware.hc.cn/example000-redis-cluster scaled
  6. # kubectl get rec --all-namespaces
  7. NAMESPACE     NAME                       DESIRED   PAUSE   AGE
  8. kube-system   example000-redis-cluster   10        true    10h
  9. # kubectl get rec example000-redis-cluster -n kube-system -o jsonpath="{.spec.replicas}"
  10. 10
打印其他列

从 Kubernetes 1.11 开始，kubectl 使用服务器端打印。服务器决定 kubectl get 命令显示哪些列。您可以使用 CustomResourceDefinition 自定义这些列。下面的示例将输出 Spec、Replicas 和 Age 列。

将 CustomResourceDefinition保存到 redis-cluster-crd.yaml。

</>复制代码 
  1. apiVersion: apiextensions.k8s.io/v1beta1
  2. kind: CustomResourceDefinition
  3. metadata:
  4.   name: redisclusters.redis.middleware.hc.cn
  5. spec:
  6.   group: redis.middleware.hc.cn
  7.   versions:
  8.     - name: v1alpha1
  9.       # Each version can be enabled/disabled by Served flag.
  10.       served: true
  11.       # One and only one version must be marked as the storage version.

</>复制代码 
  1.  scope: Namespaced
  2.  names:
  3.    kind: RedisCluster
  4.    singular: rediscluster
  5.    listKind: RedisClusterList
  6.    plural: redisclusters
  7.    shortNames:
  8.    - rec
  9.    # 执行kubectl get all时会查到pod、service、该crd等属于all categories的资源对象
  10.    categories:
  11.    - all
  12.  additionalPrinterColumns:
  13.  - name: DESIRED
  14.    type: integer
  15.    description: The number of statefulset managed by the this redisCluster
  16.    JSONPath: .spec.replicas
  17.    # boolean,date,integer,number,string
  18.  - name: PAUSE
  19.    type: boolean
  20.    description: Whether this redisCluster"s grandson (pod) will not be managed by statefulset
  21.    JSONPath: .spec.pause
</>复制代码 
  1. 2. 创建 CustomResourceDefinition：

kubectl create -f redis-cluster-crd.yaml

</>复制代码 
  1. 3. 使用上面创建的 `redis-cluster-cr.yaml` 实例。
  2. 4. 调用服务器端打印：

kubectl get rec --all-namespaces

</>复制代码 
  1. 请注意 `NAME`、`NAMESPACE`, `DESIRED`、`PAUSE` 和 `AGE` 在输出列，并且都被转成了大写字母：

[root@master-192 redis-container]# kubectl get rec --all-namespaces
NAMESPACE NAME DESIRED PAUSE AGE
kube-system example000-redis-cluster 6 true 10h

</>复制代码 
  1. `NAME`和`NAMESPACE` 列是隐含的，不需要在 CustomResourceDefinition 中定义。
  2. ## operator中应用该特性
  3. 在golang编写的operator代码中创建该结构体：

//创建CRD
func CreateRedisClusterCRD(extensionCRClient *extensionsclient.Clientset) error {

</>复制代码 
  1. //add CustomResourceValidation due to guarantee redis operator work normally
  2. labelSelectorPath := ".status.labelSelector"
  3. replicasMinimum := float64(0)
  4. replicasMaximum := float64(50)
  5. replicasMultipleOf := float64(2)
  6. slotsMinimum := float64(1)
  7. slotsMaximum := float64(16384)
  8. assignStr := "AssignReceive"
  9. autoStr := "AutoReceive"
  10. assignJson, _ := json.Marshal(assignStr)
  11. autoJson, _ := json.Marshal(autoStr)
  12. crd := &v1beta1.CustomResourceDefinition{
  13.     ObjectMeta: metav1.ObjectMeta{
  14.         Name: "redisclusters." + v1alpha1.SchemeGroupVersion.Group,
  15.     },
  16.     Spec: v1beta1.CustomResourceDefinitionSpec{
  17.         Group:   v1alpha1.SchemeGroupVersion.Group,
  18.         Versions: []v1beta1.CustomResourceDefinitionVersion {
  19.             {
  20.                 // Served is a flag enabling/disabling this version from being served via REST APIs
  21.                 Served: true,
  22.                 Name: v1alpha1.SchemeGroupVersion.Version,
  23.                 // Storage flags the version as storage version. There must be exactly one flagged as storage version
  24.                 Storage: true,
  25.             },
  26.         },
  27.         Scope:   v1beta1.NamespaceScoped,
  28.         Names: v1beta1.CustomResourceDefinitionNames{
  29.             Kind:       "RedisCluster",
  30.             ListKind:   "RedisClusterList",
  31.             Plural:     "redisclusters",
  32.             Singular:   "rediscluster",
  33.             ShortNames: []string{"rec"},
  34.             Categories: []string{"all"},
  35.         },
  36.         Subresources: &v1beta1.CustomResourceSubresources {
  37.             Status: &v1beta1.CustomResourceSubresourceStatus {},
  38.             Scale: &v1beta1.CustomResourceSubresourceScale {
  39.                 SpecReplicasPath: ".spec.replicas",
  40.                 StatusReplicasPath: ".status.replicas",
  41.                 LabelSelectorPath: &labelSelectorPath,
  42.             },
  43.         },
  44.         AdditionalPrinterColumns: []v1beta1.CustomResourceColumnDefinition{
  45.             {
  46.                 Name: "DESIRED",
  47.                 Type: "integer",
  48.                 Description: "The number of statefulset managed by the this redisCluster",
  49.                 JSONPath: ".spec.replicas",
  50.             },
  51.             {
  52.                 Name: "PAUSE",
  53.                 Type: "boolean",
  54.                 Description: "Whether this redisCluster"s grandson (pod) will not be managed by statefulset",
  55.                 JSONPath: ".spec.pause",
  56.             },
  57.             {
  58.                 Name: "AGE",
  59.                 Type: "date",
  60.                 JSONPath: ".metadata.creationTimestamp",
  61.             },
  62.         },
  63.         Validation: &v1beta1.CustomResourceValidation {
  64.             OpenAPIV3Schema: &v1beta1.JSONSchemaProps {
  65.                 Properties: map[string]v1beta1.JSONSchemaProps {
  66.                     "spec": {
  67.                         Required: []string{"replicas", "repository", "version"},
  68.                         Properties: map[string]v1beta1.JSONSchemaProps{
  69.                             "pause": {
  70.                                 Type: "boolean",
  71.                             },
  72.                             "replicas": {
  73.                                 Type:       "integer",
  74.                                 Minimum:    &replicasMinimum,
  75.                                 Maximum:    &replicasMaximum,
  76.                                 MultipleOf: &replicasMultipleOf,
  77.                             },
  78.                             "updateStrategy": {
  79.                                 Type: "object",
  80.                                 Properties: map[string]v1beta1.JSONSchemaProps{
  81.                                     "type": {
  82.                                         Type: "string",
  83.                                         Enum: []v1beta1.JSON {
  84.                                             {
  85.                                                 //这里必须是JSON格式的字符串
  86.                                                 Raw: assignJson,
  87.                                             },
  88.                                             {
  89.                                                 Raw: autoJson,
  90.                                             },
  91.                                         },
  92.                                     },
  93.                                     "pipeline": {
  94.                                         Type:    "string",
  95.                                         Pattern: `^([1-9][0-9]*){1,3}$`,
  96.                                     },
  97.                                     "assignStrategies": {
  98.                                         Type: "array",
  99.                                         Items: &v1beta1.JSONSchemaPropsOrArray{
  100.                                             Schema: &v1beta1.JSONSchemaProps{
  101.                                                 Type: "object",
  102.                                                 Properties: map[string]v1beta1.JSONSchemaProps{
  103.                                                     "slots": {
  104.                                                         Type:    "integer",
  105.                                                         Minimum: &slotsMinimum,
  106.                                                         Maximum: &slotsMaximum,
  107.                                                     },
  108.                                                     "fromReplicas": {
  109.                                                         Type:    "string",
  110.                                                         Pattern: `^[a-z0-9,]{3,}$`,
  111.                                                     },
  112.                                                 },
  113.                                             },
  114.                                         },
  115.                                     },
  116.                                 },
  117.                             },
  118.                         },
  119.                     },
  120.                     "pod": {
  121.                         Type: "array",
  122.                         Items: &v1beta1.JSONSchemaPropsOrArray {
  123.                             Schema: &v1beta1.JSONSchemaProps {
  124.                                 Type: "object",
  125.                                 Required: []string{"replicas", "repository", "version"},
  126.                                 Properties: map[string]v1beta1.JSONSchemaProps{
  127.                                     "configmap": {
  128.                                         Type: "string",
  129.                                     },
  130.                                     "monitorImage": {
  131.                                         Type: "string",
  132.                                     },
  133.                                     "initImage": {
  134.                                         Type: "string",
  135.                                     },
  136.                                     "middlewareImage": {
  137.                                         Type: "string",
  138.                                     },
  139.                                 },
  140.                             },
  141.                         },
  142.                     },
  143.                 },
  144.             },
  145.         },
  146.     },
  147. }
  148. _, err := extensionCRClient.ApiextensionsV1beta1().CustomResourceDefinitions().Create(crd)
  149. return err

}

</>复制代码 
  2. ## 参考
  3. 官方Extend the Kubernetes API with CustomResourceDefinitions：
  4. https://kubernetes.io/docs/tasks/access-kubernetes-api/custom-resources/custom-resource-definitions/
  5. feature-gates参数说明：
  6. https://kubernetes.io/docs/reference/command-line-tools-reference/feature-gates/
  7. CustomResourceDefinition中文文档：
  8. https://kubernetes.feisky.xyz/cha-jian-kuo-zhan/api/customresourcedefinition
  9. swagger和openAPI: 数据类型：
  10. https://www.breakyizhan.com/swagger/2969.html
  11. 正则表达式：
  12. https://www.cnblogs.com/afarmer/archive/2011/08/29/2158860.html
  13. ----
  14. ---
  15. 本公众号免费提供csdn下载服务，海量IT学习资源，如果你准备入IT坑，励志成为优秀的程序猿，那么这些资源很适合你，包括但不限于java、go、python、springcloud、elk、嵌入式 、大数据、面试资料、前端 等资源。同时我们组建了一个技术交流群，里面有很多大佬，会不定时分享技术文章，如果你想来一起学习提高，可以公众号后台回复【2】，免费邀请加技术交流群互相学习提高，会不定期分享编程IT相关资源。
  16. **扫码关注，精彩内容第一时间推给你**
GPU云服务器 云服务器 自定义对象 自定义 头像自定义 网站自定义

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/32980.html

相关文章

  • kubernetes自定义资源对象高级功能

    摘要：可以通过验证自定义对象是否符合标准。此功能可用于及以上版本自定义资源。状态和规范节分别由自定义资源内的和表示。对子资源的请求采用自定义资源对象，并忽略除状态节之外的任何更改。该对象作为有效负载发送。 kubernetes自定义资源对象高级功能 本文首发于微信公众号我的小碗汤，扫码文末二维码即可关注，欢迎一起交流！ kubernetes自定义资源对象再极大程度提高了API Server的...

    Mr_zhang 评论0 收藏0

  • 来说说Kubernetes的运作机制

    摘要：提供用于获取有关容器和容器组状态的实时信息的服务，以及有关群集中开发人员操作的详细信息。集群最高级别的抽象是指运行本身是集群应用程序的一组机器及其管理的容器，一个集群必须有一个，即命令和控制集群中所有其他机器的系统。Docker容器改变了人们对开发、部署和维护软件的思考方式，利用现代操作系统的本机隔离功能，容器支持类似于虚拟机的关注点分离，但是与基于虚拟机监控程序的虚拟机相比，它的开销要小得...

    yanest 评论0 收藏0

  • Kubernetes准入控制器指南

    摘要：安全功能的最新引入是一组称为准入控制器的插件。通过将标志传递给服务器来配置启用的准入控制器集。本讨论将仅关注基于的准入控制器。摘要准入控制器为安全性提供了显着优势。 作者：Malte Isberner（StackRox） Kubernetes极大地提高了当今生产中后端群集的速度和可管理性。由于其灵活性、可扩展性和易用性，Kubernetes已成为容器编排器的事实标准。Kubernete...

    solocoder 评论0 收藏0

  • Kubernetes准入控制器指南

    摘要：安全功能的最新引入是一组称为准入控制器的插件。通过将标志传递给服务器来配置启用的准入控制器集。本讨论将仅关注基于的准入控制器。摘要准入控制器为安全性提供了显着优势。 作者：Malte Isberner（StackRox） Kubernetes极大地提高了当今生产中后端群集的速度和可管理性。由于其灵活性、可扩展性和易用性，Kubernetes已成为容器编排器的事实标准。Kubernete...

    Loong_T 评论0 收藏0

  • Rancher 2.0快速上手指南

    摘要：而用户能在同一平台上管理任何集群，轻松地充分利用的强大能力及其迅速壮大的生态系统。在本指南中，你将会了解如何快速上手。环境中的所有主机必须允许彼此间的流量能够进行跨主机联网。这一过程需要几分钟完成。如果服务正常，将会显示状态为绿色。 大家好，给大家介绍一下，这是帮助大家率先上手尝试Rancher 2.0的神器 @Rancher 2.0快速上手指南 内容导读 准备一台Linux主机 启...

    xiaodao 评论0 收藏0

发表评论

登陆后可评论

0条评论

陈江龙

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<