使用Golang的k8s客户端监视并等待POD的删除

怎么入门Golang编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《使用Golang的k8s客户端监视并等待POD的删除》，涉及到，有需要的可以收藏一下

我需要观察（并等待）直到 pod 被删除。我需要这样做是因为我需要在第一个 pod 被删除后立即启动第二个 pod（同名）。

这就是我正在尝试的：

func (k *k8sclient) waitpoddeleted(ctx context.context, resname string) error {
    watcher, err := k.createpodwatcher(ctx, resname)
    if err != nil {
        return err
    }

    defer watcher.stop()

    for {
        select {
        case event := <-watcher.resultchan():

            if event.type == watch.deleted {
                k.logger.debugf("the pod \"%s\" is deleted", resname)

                return nil
            }

        case <-ctx.done():
            k.logger.debugf("exit from waitpoddeleted for pod \"%s\" because the context is done", resname)
            return nil
        }
    }
}

这种方法的问题是，当我收到 deleted 事件时，是 pod 收到删除事件时，而不是实际删除时。做了一些额外的测试，我用以下代码结束了调试过程：

case event := <-watcher.resultchan():

    if event.type == watch.deleted {
        pod := event.object.(*v1.pod)
        k.logger.debugf("event %s phase %s message %s", event.type, pod.status.phase, pod.status.message)
    }

此操作的日志结果是：

2022-02-15T08:21:51 DEBUG EVENT DELETED PHASE Running MESSAGE
2022-02-15T08:22:21 DEBUG EVENT DELETED PHASE Running MESSAGE

我收到两个已删除事件。我立即发送第一个删除命令。 pod 从集群中有效删除时的最后一个。

我的问题是：

• 为什么我收到两个“已删除”事件？我如何区分一个与另一个？我尝试比较这两个事件，它们看起来完全相同（时间戳除外）
• 观察并等待 pod 删除的最佳方法是什么，以便我可以立即重新启动它？我应该轮询 api 直到 pod 未返回吗？

我试图解决的用例： 在我的应用程序中，有一个功能可以用具有不同选项的另一个工具替换工具。该功能需要删除包含该工具的 pod，并使用另一组选项重新启动它。在这种情况下，我需要等待 pod 删除，以便再次启动它。

提前致谢！

正确答案

正如我在评论中所说，真正的问题是我创建的观察程序来监视我想要删除的 pod。在观察器中，我创建了一个 labelselector，它选择两个而不是一个 pod。这是完整的解决方案，包括观察者。

func (k *k8sClient) createPodWatcher(ctx context.Context, resName string) (watch.Interface, error) {
    labelSelector := fmt.Sprintf("app.kubernetes.io/instance=%s", resName)
    k.logger.Debugf("Creating watcher for POD with label: %s", labelSelector)

    opts := metav1.ListOptions{
        TypeMeta:      metav1.TypeMeta{},
        LabelSelector: labelSelector,
        FieldSelector: "",
    }

    return k.clientset.CoreV1().Pods(k.cfg.Kubernetes.Namespace).Watch(ctx, opts)
}

func (k *k8sClient) waitPodDeleted(ctx context.Context, resName string) error {
    watcher, err := k.createPodWatcher(ctx, resName)
    if err != nil {
        return err
    }

    defer watcher.Stop()

    for {
        select {
        case event := <-watcher.ResultChan():

            if event.Type == watch.Deleted {
                k.logger.Debugf("The POD \"%s\" is deleted", resName)

                return nil
            }

        case <-ctx.Done():
            k.logger.Debugf("Exit from waitPodDeleted for POD \"%s\" because the context is done", resName)
            return nil
        }
    }
}

func (k *k8sClient) waitPodRunning(ctx context.Context, resName string) error {
    watcher, err := k.createPodWatcher(ctx, resName)
    if err != nil {
        return err
    }

    defer watcher.Stop()

    for {
        select {
        case event := <-watcher.ResultChan():
            pod := event.Object.(*v1.Pod)

            if pod.Status.Phase == v1.PodRunning {
                k.logger.Infof("The POD \"%s\" is running", resName)
                return nil
            }

        case <-ctx.Done():
            k.logger.Debugf("Exit from waitPodRunning for POD \"%s\" because the context is done", resName)
            return nil
        }
    }
}

本篇关于《使用Golang的k8s客户端监视并等待POD的删除》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！