common

Documentation

Index

• func CheckPort(port int) error
• func Execute(clientset *kubernetes.Clientset, restcfg *restclient.Config, ...) (string, error)
• func GetPod(podName, containerName, namespace string, clientset *kubernetes.Clientset, ...) (*corev1.Pod, error)
• type ExecTarget
• type PortForwarder
  • func NewPortForwarder(clientset *kubernetes.Clientset, restcfg *restclient.Config, pod *corev1.Pod, ...) *PortForwarder
  • func (p *PortForwarder) Start() error
  • func (p *PortForwarder) Stop()

Functions

func CheckPort

func CheckPort(port int) error

func Execute

func Execute(clientset *kubernetes.Clientset, restcfg *restclient.Config, target *ExecTarget, cmd string, toStdout, toStdin bool) (string, error)

func GetPod

func GetPod(podName, containerName, namespace string, clientset *kubernetes.Clientset, restcfg *restclient.Config) (*corev1.Pod, error)

Types

type ExecTarget

type ExecTarget struct {
	Pod       *corev1.Pod
	Container string
}

type PortForwarder

type PortForwarder struct {
	Clientset  *kubernetes.Clientset
	RestConfig *restclient.Config
	Pod        *corev1.Pod
	LocalPort  int
	PodPort    int
	Streams    genericclioptions.IOStreams
	StopCh     chan struct{}
	ReadyCh    chan struct{}
	Started    bool
}

func NewPortForwarder

func NewPortForwarder(clientset *kubernetes.Clientset, restcfg *restclient.Config, pod *corev1.Pod, podPort, localPort int) *PortForwarder

func (*PortForwarder) Start

func (p *PortForwarder) Start() error

func (*PortForwarder) Stop

func (p *PortForwarder) Stop()