附录：CUE 操作符

这个文档介绍 step 定义过程中，可以使用的 CUE 操作类型。这些操作均由 vela/op 包提供。

可以阅读 CUE 基础文档来学习 CUE 基础语法。

在 Kubernetes 集群中创建或者更新资源。

value: 将被 apply 的资源的定义。操作成功执行后，会用集群中资源的状态重新渲染 value。
patch: 对 value 的内容打补丁，支持策略性合并，比如可以通过注释 // +patchKey 实现数组的按主键合并。

#Apply: {
  value: {...}
  patch: {
    // patchKey=$key
    ...
  }
}

import "vela/op"
stepName: op.#Apply & {
  value: {
    kind: "Deployment"
    apiVersion: "apps/v1"
    metadata: name: "test-app"
    spec: { 
      replicas: 2
      ...
    }
  }
  patch: {
   spec: template: spec: {
      // patchKey=name
      containers: [{name: "sidecar"}]
   }
  }
}

会让 workflow step 处于等待状态，直到条件被满足。

continue: 当该字段为 true 时，workflow step 才会恢复继续执行。

#ConditionalWait: {
  continue: bool
}

import "vela/op"
apply: op.#Apply
wait: op.#ConditionalWait & {
  continue: apply.value.status.phase=="running"
}

获取 Application 中所有组件对应的资源数据。

无需指定参数。

#Load: {}

import "vela/op"
// 该操作完成后，你可以使用 `load.value.[componentName]` 来获取到对应组件的资源数据
load: op.#Load & {}

读取 Kubernetes 集群中的资源。

value: 需要用户描述读取资源的元数据，比如 kind、name 等，操作完成后，集群中资源的数据会被填充到 value 上。
err: 如果读取操作发生错误，这里会以字符串的方式指示错误信息。

#Read: {
  value: {}
  err?: string
}

// 操作完成后，你可以通过 configmap.value.data 使用 configmap 里面的数据
configmap: op.#Read & {
   value: {
      kind: "ConfigMap"
      apiVersion: "v1"
      metadata: {
        name: "configmap-name"
        namespace: "configmap-ns"
      }
   }
}

在 Kubernetes 集群中创建或者更新应用对应的所有资源。

无需指定参数。

#ApplyApplication: {}

apply: op.#ApplyApplication & {}

在 Kubernetes 集群中创建或者更新组件对应的所有资源。注意，在使用该操作前需要先用 Load 加载资源。

value: 指定需要 apply 的资源定义。
patch: 指定需要 patch 的资源定义

#ApplyComponent: {
  value: {...}
  patch: {...}
}

load: op.#Load & {}
apply: op.#ApplyComponent & {
  value: load.value[parameter.component]
}

在 Kubernetes 集群中创建或者更新 Application 中所有组件对应的资源,并可以通过 exceptions 指明哪些组件或者组件中的某些资源跳过创建和更新。

exceptions: 指明该操作需要排除掉的组件。

#ApplyRemaining: {
 exceptions?: [...string]
}

apply: op.#ApplyRemaining & {
  exceptions: ["applied-component-name"]
}

向 Slack 发送消息通知。

url: Slack 的 Webhook 地址。
message: 需要发送的 Slack 消息，需要符合 Slack 信息规范。

#Slack: {
  url: string
  message: {...}
}

apply: op.#Slack & {
  url: webhook url
  message:
    text: Hello KubeVela
}

向钉钉发送消息通知。

url: 钉钉的 Webhook 地址。
message: 需要发送的钉钉消息，需要符合钉钉信息规范。

#DingTalk: {
  url: string
  message: {...}
}

apply: op.#DingTalk & {
  url: webhook url
  message:
    msgtype: text
    text:
      context: Hello KubeVela
}

用来封装一组操作。

steps 里面需要通过 tag 的方式指定执行顺序，数字越小执行越靠前。

app: op.#Steps & {
  load: op.#Load & {
    component: "component-name"
  } @step(1)
  apply: op.#Apply & {
    value: load.value.workload
  } @step(2)
}

用来在workflow的上下文中保存或者读取用户定义的数据

method: 值为Get或者Put，用于表示该动作是从 workflow 中读取还是保存数据
path: 数据保存或者读取的路径
value: 数据内容(格式为 cue )，当 method 为 Get 表示读取到的数据，当 method 为 Put 时表示要保存的数据

put: op.ws.#DoVar & {
  method: "Put"
  path: "foo.score"
  value: 100
}
// 用户可以通过get.value拿到上面保存的数据(100)
get: op.ws.#DoVar & {
  method: "Get"
  path: "foo.score"
}

Last updated on 2022年11月1日 by Tianxin Dong