2

我们已经通过 kubebuilder 2.0 成功构建了一个 operator。在这个操作符中，我们需要在使用 k8s.io/client-go/kubernetes.Clientset 之前在 pod 中运行一个 cmd，它会抓取 restconfig 并像这样运行

   execReq := o.clientset.CoreV1().RESTClient().Post().
        Resource("pods").
        Name(Podname).
        Namespace("default").
        SubResource("exec")

   execReq.VersionedParams(&corev1.PodExecOptions{
        Command:   SqlCommand,
        Stdin:     true,
        Stdout:    true,
        Stderr:    true,
        }, scheme.ParameterCodec)

    exec, err := remotecommand.NewSPDYExecutor(o.restConfig, "POST", execReq.URL())
    if err != nil {
        return fmt.Errorf("error while creating Executor: %v", err)
    }

    err = exec.Stream(remotecommand.StreamOptions{
            Stdin:  os.Stdin,
            Stdout: os.Stdout,
            Stderr: os.Stderr,
            Tty:    false,
        })
    if err != nil {
        return fmt.Errorf("error in Stream: %v", err)
    } else {
        return nil
    }

在控制器运行时世界中，我无法从控制器运行时的客户端找到任何 RESTClient 。

我想知道我们如何在操作员的 pod 中执行 cmd？

谢谢（编辑）

4

0 回答 0