使用 kubectl 在 Go 命令中检索更新输出

从现在开始，努力学习吧！本文《使用 kubectl 在 Go 命令中检索更新输出》主要讲解了等等相关知识点，我会在golang学习网中持续更新相关的系列文章，欢迎大家关注并积极留言建议。下面就先一起来看一下本篇正文内容吧，希望能帮到你！

我已经使用 go 实现了 cli，并显示了 kubernetese 单元的状态。命令为cellery ps

func ps() error {
    cmd := exec.Command("kubectl", "get", "cells")
    stdoutReader, _ := cmd.StdoutPipe()
    stdoutScanner := bufio.NewScanner(stdoutReader)
    go func() {
        for stdoutScanner.Scan() {
            fmt.Println(stdoutScanner.Text())
        }
    }()
    stderrReader, _ := cmd.StderrPipe()
    stderrScanner := bufio.NewScanner(stderrReader)
    go func() {
        for stderrScanner.Scan() {
            fmt.Println(stderrScanner.Text())
            if (stderrScanner.Text() == "No resources found.") {
                os.Exit(0)
            }
        }
    }()
    err := cmd.Start()
    if err != nil {
        fmt.Printf("Error in executing cell ps: %v \n", err)
        os.Exit(1)
    }
    err = cmd.Wait()
    if err != nil {
        fmt.Printf("\x1b[31;1m Cell ps finished with error: \x1b[0m %v \n", err)
        os.Exit(1)
    }
    return nil
}

但是，单元在部署时需要时间才能进入就绪状态。因此我需要给出一个标志（等待）来更新 cli 输出。

命令为 cellery ps -w 。然而 kubernetese api 还没有实现这一点。所以我必须想出一个命令。

解决方案

基本上你想要的是监听单元准备就绪的事件。 您可以注册集群中的事件并对其采取行动。可以找到一个很好的例子 here

今天关于《使用 kubectl 在 Go 命令中检索更新输出》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！