Команда Go, чтобы получить обновленный вывод, используя kubectl - PullRequest
Новая
       10

Команда Go, чтобы получить обновленный вывод, используя kubectl

0 голосов
/ 11 января 2019

Я реализовал CLI, используя go, и я отображаю состояние ячеек кубернетеза. Команда 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
}

Однако ячейкам нужно время, чтобы войти в состояние готовности, когда они развернуты. Поэтому мне нужно указать флаг (wait), который бы обновлял вывод CLI.

Команда будет cellery ps -w. Однако API Kubernetese еще не реализовали это. Поэтому мне придется придумать команду.

1 Ответ

0 голосов
/ 11 января 2019

По сути, вы хотите прослушать событие готовности клетки. Вы можете зарегистрироваться на события в кластере и действовать в соответствии с ними. Хороший пример можно найти здесь

...