去年，我开始使用 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 个条件。
假设我有一个协调循环，我想在其中创建一个 pod。该条件的目标是从初始化并进展到两个结果之一：如果成功则创建，如果过程中出现错误则出错。
兴泰网络办公系统1.61
下载
基于 Internet 的 Web 技术，完全采用B/S 体系结构的网络办公系统。该系统具有安全性高、功能极为强大、可在广域网中使用也可在局域网中使用、也可以同时在局域网和广域网中使用的特点，全傻瓜式安装，无需作复杂配置，界面采用类似windows资源管理器的设计，结构清晰，条理分明，即使不熟悉电脑的人也可很快掌握全部操作。该系统通过在广域网内的广泛试用验证和经专业技术人员的调试、测试，确认具有很
咨询锁定条件
由于协调循环在分布式数据库（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 上获取。
