去年，我开始使用 kubebuilder 为各种事情构建操作符。在整个操作员中，我广泛使用条件来管理自定义资源协调流程的每个步骤。

不幸的是，sigs.k8s.io 的条件让我想要更多。我遇到了一些冲突、破坏状态等问题。随着我对问题的深入研究，我开始围绕条件的使用创建一种框架。

我最近终于花了一些时间将这些发现打包到一个库中供其他人使用。我称其为conditionner。 konditionner 的核心目标是提供：

• 完全可扩展的条件类型和状态
• 用于处理条件的实用程序 api
• 咨询锁

如何使用

import "github.com/pier-oliviert/konditionner/pkg/konditions"

buildcondition        konditions.conditiontype = "builds"
networkcondition      konditions.conditiontype = "network"
podcondition          konditions.conditiontype = "pod"
dependenciescondition konditions.conditiontype = "dependency"
variablescondition    konditions.conditiontype = "variables"

type mycrd struct {
    metav1.typemeta   `json:",inline"`
    metav1.objectmeta `json:"metadata,omitempty"`

    spec   myspec   `json:"spec,omitempty"`
    status mystatus `json:"status,omitempty"`
}

// conditionalresource interface, more about it in the advisory lock
// section
func (m mycrd) *konditions.conditions {
   return &m.status.conditions
}

type myspec struct {
   // ... my fields ...
}

type mystatus struct {
    // ... my fields ...

    conditions konditions.conditions `json:"conditions,omitempty"`
}

mycrd 自定义资源非常简单，但已经可以使用了！ konditionner 没有定义任何类型，因为它特定于每种用途。在这里，我创建了其中 5 个，这意味着我将在协调循环中使用 5 个条件。

One-click installation of GitHub projects

GInstall OneClick — 一键安装 GitHub 项目：规划、克隆、安装 Node 依赖、运行开发脚本。适用于想要获取 GitHubNode.js 项目的用户。

下载

假设我有一个协调循环，我想在其中创建一个 pod。该条件的目标是从初始化并进展到两个结果之一：如果成功则创建，如果过程中出现错误则出错。

咨询锁定条件

由于协调循环在分布式数据库（etcd）和缓存层之上工作，我发现在执行任务之前在条件上创建“锁”要可靠得多。

func (r reconciler) reconcile(ctx context.context, req ctrl.request) (ctrl.result, error) {
    var record mycrd
    if err := r.get(ctx, req, &record); err != nil {
        return ctrl.result{}, err
    }

    lock := konditions.newlock(record, r.client, podcondition)
    if lock.condition().status == konditions.conditionerror {
      // nothing to do
      return ctrl.result{}, err
    }

    if lock.condition().status == konditions.conditioninitialized {
      lock.execute(ctx, func(condition konditions.condition) error {
        pod, err := createpod()
        if err != nil { return err }
        condition.status = konditions.conditioncreated
        condition.reason = fmt.sprintf("pod created: %s", pod.name)
        record.conditions().setcondition(condition)
        return nil
})
    }
}

为了使锁发挥作用，记录需要遵守 konditions.conditionalresource 接口。这就是为什么自定义资源在顶部定义了 conditions() 方法：

func (m MyCRD) *konditions.Conditions {
   return &m.Status.Conditions
}

文档可在 pkg.go.dev 上获取，源代码可在 github 上获取。