Go 命令使用 kubectl 获取更新的输出

Question

我已经使用 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。但是 Kubernetes API 还没有实现这个。所以我将不得不想出一个命令。

Answer 1

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

Go 命令使用 kubectl 获取更新的输出

Go command to get updated output using kubectl

go

kubernetes

kubectl