kubeletconfig

Documentation

Index

• Constants
• func FindProxyPort(r io.Reader) (int, error)
• func GetKubeletConfigForNodes(kc *Kubectl, nodeNames []string, logger logr.Logger) (k8sconf map[string]*kubeletconfigv1beta1.KubeletConfiguration, err error)
• func StartWithStreamOutput(cmd *exec.Cmd) (stdout, stderr io.ReadCloser, err error)
• type Kubectl
  • func NewKubectl(logger logr.Logger, kubectlPath, kubeConfig string) *Kubectl
  • func NewKubectlFromEnv(logger logr.Logger) *Kubectl
  • func (kc *Kubectl) Arguments(args ...string) []string
  • func (kc *Kubectl) Command(args ...string) *exec.Cmd
  • func (kc *Kubectl) IsReady() (bool, error)
  • func (kc *Kubectl) WithAPIServer(apiserver string) *Kubectl
  • func (kc *Kubectl) WithNamespace(namespace string) *Kubectl

Constants

const (
	DefaultKubectlPath = "/bin/kubectl"
)

Functions

func FindProxyPort

func FindProxyPort(r io.Reader) (int, error)

func GetKubeletConfigForNodes

func GetKubeletConfigForNodes(kc *Kubectl, nodeNames []string, logger logr.Logger) (k8sconf map[string]*kubeletconfigv1beta1.KubeletConfiguration, err error)

func StartWithStreamOutput

func StartWithStreamOutput(cmd *exec.Cmd) (stdout, stderr io.ReadCloser, err error)

Types

type Kubectl

type Kubectl struct {
	// contains filtered or unexported fields
}

func NewKubectl

func NewKubectl(logger logr.Logger, kubectlPath, kubeConfig string) *Kubectl

func NewKubectlFromEnv

func NewKubectlFromEnv(logger logr.Logger) *Kubectl

func (*Kubectl) Arguments

func (kc *Kubectl) Arguments(args ...string) []string

func (*Kubectl) Command

func (kc *Kubectl) Command(args ...string) *exec.Cmd

func (*Kubectl) IsReady

func (kc *Kubectl) IsReady() (bool, error)

func (*Kubectl) WithAPIServer

func (kc *Kubectl) WithAPIServer(apiserver string) *Kubectl

func (*Kubectl) WithNamespace

func (kc *Kubectl) WithNamespace(namespace string) *Kubectl