创建k8s资源并等待完成继续下一步

Question

我需要创建一个 k8s 资源，这需要一些时间才能可用，为此我使用以下命令

https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg/controller/controllerutil#example-CreateOrUpdate

op, err := controllerutil.CreateOrUpdate(context.TODO(), c, deploy, func() error {

})

func2()

func2 现在我需要在对象创建完成后立即调用（可能需要 2-3 分钟才能完成），我应该如何做？

我发现了这个，但不知道如何将它们结合起来......

https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg#hdr-Watching_and_EventHandling

我正在使用 kubebuilder

Answer 1

上面的方法更适合cli使用。

当您使用 kubebuilder 或 Operator sdk 时，您需要在协调函数中处理它。

通常，您有一个自定义资源可以触发控制器协调功能。创建自定义资源后，您可以创建部署，而不是返回空的 reconcile.Result（将其标记为已完成），您可以返回带有 Requeue 属性的 reconcile.Result。

reconcile.Result{Requeue: true}

因此，在下次运行期间，您检查部署是否准备就绪。如果没有，那么您再次重新排队。一旦准备好，您将返回一个空的 reconcile.Result 结构。

另请记住，协调函数始终需要是幂等的，因为它将在控制器重新启动期间以及默认情况下每 10 小时再次运行一次。

或者，您也可以在创建的部署上使用所有者引用，然后设置控制器以在所拥有的资源（部署）上发生更新时协调所有者资源（您的自定义资源）。对于operator sdk，可以在SetupWithManager函数中进行配置，默认情况下仅使用For选项函数。这里需要添加Owns选项功能。

// SetupWithManager sets up the controller with the Manager.
func (r *YourReconciler) SetupWithManager(mgr ctrl.Manager) error {
    return ctrl.NewControllerManagedBy(mgr).
        For(&yourapigroup.YourCustomResource{}).
        Owns(&appv1.Deployment{}).
        Complete(r)
}

我从未使用过这种方法，因此可能需要添加更多代码才能使其工作。

如果您不需要任何终结器代码，那么使用所有者引用也会派上用场，因为在删除自定义资源时，kubernetes 会自动删除您拥有的资源（部署）。