观察 pod 状态的所有变化

Question

我正在尝试编写行为类似于 kubectl get pods --watch. 这样，每当 pod 的状态发生变化时，我都会被触发。

我创建了一个go项目（在集群中运行）并添加了以下代码：

podsWatcher, err := restAPIClient.CoreV1().Pods("").Watch(globalHTTPContext, metav1.ListOptions{Watch: true})

if err != nil {

    // do something

}

podsChan := podsWatcher.ResultChan()

for event := range podsChan {

    switch event.Type {

    case watch.Added:

        // do something

    case watch.Modified:

        // do something

    case watch.Deleted:

        // do something

    case watch.Bookmark:

        // do something

    case watch.Error:

        // do something

    }

}

每次对 pod 进行重大更改时，我都会收到一个事件，但不是针对所有事件。（事件）。

如何触发 Pod 状态中发生的每一个变化（如--watch标志）？

Answer 1

显然，手表是由每次更改（在 pod describe 中进行的）触发的，我正在查看pod.status.phase而不是查看pod.Status.ContainerStatuses，这就是为什么我认为我没有收到每个事件。我添加了一个函数来处理以下事件：// get ContainerStatuses. If there is no containerStatus, return the pod phasefunc getPodStatus(pod *core.Pod) string {    containerStatuses := pod.Status.ContainerStatuses    status := ""    if len(containerStatuses) > 0 {        for i := range containerStatuses {            if containerStatuses[i].State.Terminated != nil {                status = containerStatuses[i].State.Terminated.Reason            }            if containerStatuses[i].State.Waiting != nil {                status = containerStatuses[i].State.Waiting.Reason            }            if containerStatuses[i].State.Running != nil {                if status == "" { // if none of the containers report an error                    status = "Running"                }            }        }    }    if status == "" {        status = string(pod.Status.Phase)    }    return status}// PodWatch watch pod changes in all namespacesfunc PodWatch() error {    podsWatcher, err := restAPIClient.CoreV1().Pods("").Watch(globalHTTPContext, metav1.ListOptions{Watch: true})    if err != nil {        return err    }    podsChan := podsWatcher.ResultChan()    for event := range podsChan {        pod, err := event.Object.(*core.Pod)        if err != nil {            return err        }        switch event.Type {        case watch.Added:            fmt.Println(getPodStatus(pod))        case watch.Modified:            fmt.Println(getPodStatus(pod))        case watch.Deleted:            fmt.Println(getPodStatus(pod))        case watch.Bookmark:            fmt.Println(getPodStatus(pod))        case watch.Error:            fmt.Println(getPodStatus(pod))        }    }}这个解决方案适合我的需要，如果你想实现--watch类似 kubectl，你可以在这里找到实现。