kubectl插件里面，提示输入？

Question

我正在编写一个kubectl插件来对用户进行身份验证，我想在调用插件后提示用户输入密码。据我了解，从 STDIN 获取输入相当简单，但我很难看到写入 STDOUT 的消息。目前我的代码如下所示：在 cmd/kubectl-myauth.go 中：// This is mostly boilerplate, but it's needed for the MRE// https://stackoverflow.com/help/minimal-reproducible-examplepackage myauthimport (...)func main() {    pflag.CommandLine = pflag.NewFlagSet("kubectl-myauth", pflag.ExitOnError)    root := cmd.NewCmdAuthOp(genericclioptions.IOStreams{In: os.Stdin, Out: os.Stdout, ErrOut: os.Stderr})    if err := root.Execute(); err != nil {        os.Exit(1)    }}在 pkg/cmd/auth.go 中：package cmd...type AuthOpOptions struct {    configFlags *genericclioptions.ConfigFlags    resultingContext *api.Context    rawConfig       api.Config    args            []string    ...    genericclioptions.IOStreams}func NewAuthOpOptions(streams genericclioptions.IOStreams) *AuthOpOptions {    return &AuthOpOptions{        configFlags: genericclioptions.NewConfigFlags(true),        IOStreams: streams,    }}func NewCmdAuthOp(streams genericclioptions.IOStreams) *cobra.Command {    o := NewAuthOpOptions(streams)    cmd := &cobra.Command{        RunE: func(c *cobra.Command, args []string) error {            return o.Run()        },    }    return cmd}func (o *AuthOpOptions) Run() error {    pass, err := getPassword(o)    if err != nil {        return err    }    // Do Auth Stuff    // Eventually print an ExecCredential to STDOUT    return nil}当从上下文外部运行时，这按照我期望的方式工作kubectl- 即，它打印字符串，提示输入，然后继续。然而，从上下文内部来看kubectl，我相信前两个全大写注释（[1] 和 [2]）之间的打印内容正在被kubectlSTDOUT 上的监听所吞没。我可以通过打印到 STDERR 来解决这个问题，但这感觉......错误。有没有办法可以绕过kubectlSTDOUT 的消耗来与用户通信？TL;DR：kubectl似乎正在吞噬kubectl插件的所有 STDOUT，但我想提示用户输入 - 有没有一种简单的方法可以做到这一点？

Answer 1

以下是步骤：

• git clone https://github.com/kubernetes/kubernetes.git

• 重复sample-cli-plugin为test-cli-plugin（这涉及在暂存/发布下修复 import-restrictions.yaml、rules-godeps.yaml 和 Rules.yaml - 也许没有必要，但这样更安全）

• 将 kubectl-ns.go 更改为 kubectl-test.go：

package main

import (

        "os"

        "github.com/spf13/pflag"

        "k8s.io/cli-runtime/pkg/genericclioptions"

        "k8s.io/test-cli-plugin/pkg/cmd"

)

func main() {

        flags := pflag.NewFlagSet("kubectl-test", pflag.ExitOnError)

        pflag.CommandLine = flags

        root := cmd.NewCmdTest(genericclioptions.IOStreams{In: os.Stdin, 

                                                           Out: os.Stdout,

                                                           ErrOut: os.Stderr})

        if err := root.Execute(); err != nil {

                os.Exit(1)

        }

}

将 ns.go 更改为 test.go：

package cmd

import (

        "fmt"

        "os"

        "github.com/spf13/cobra"

        "k8s.io/cli-runtime/pkg/genericclioptions"

)

type TestOptions struct {

        configFlags *genericclioptions.ConfigFlags

        genericclioptions.IOStreams

}

func NewTestOptions(streams genericclioptions.IOStreams) *TestOptions {

        return &TestOptions{

                configFlags: genericclioptions.NewConfigFlags(true),

                IOStreams:   streams,

        }

}

func NewCmdTest(streams genericclioptions.IOStreams) *cobra.Command {

        o := NewTestOptions(streams)

        cmd := &cobra.Command{

                Use:          "test",

                Short:        "Test plugin",

                SilenceUsage: true,

                RunE: func(c *cobra.Command, args []string) error {

                        o.Run()

                        return nil

                },

        }

        return cmd

}

func (o *TestOptions) Run() error {

        fmt.Fprintf(os.Stderr, "Testing Fprintf Stderr\n")

        fmt.Fprintf(os.Stdout, "Testing Fprintf Stdout\n")

        fmt.Printf("Testing Printf\n")

        fmt.Fprintf(o.IOStreams.Out, "Testing Fprintf o.IOStreams.Out\n")

        return nil

}

• 相应地修复 BUILD 文件

• 构建插件

• 跑步make

• 复制kubectl-test到/usr/local/bin

• 运行编译后的二进制kubectl文件：

~/k8s/_output/bin$ ./kubectl 测试

测试 Fprintf 标准错误

测试 Fprintf 标准输出

测试 Printf

测试 Fprintf o.IOStreams.Out