去年，我开始使用 kubebuilder 为各种事情构建操作符。在整个操作员中，我广泛使用条件来管理自定义资源协调流程的每个步骤。
不幸的是，sigs.k8s.io 的条件让我想要更多。我遇到了一些冲突、破坏状态等问题。随着我对问题的深入研究，我开始围绕条件的使用创建一种框架。
我最近终于花了一些时间将这些发现打包到一个库中供其他人使用。我称其为Conditionner。 Konditionner 的核心目标是提供：
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。该条件的目标是从初始化并进展到两个结果之一：如果成功则创建，如果过程中出现错误则出错。
由于协调循环在分布式数据库（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 上获取。
以上是Konditionner：管理 kcustom 资源中的条件的详细内容。更多信息请关注PHP中文网其他相关文章！
