Konditionner：管理 kcustom 资源中的条件

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"`
}

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
})
    }
}

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