portforward

Documentation

Index

• func GetPodFromService(kubeClient *kubernetes.Clientset, namespace string, serviceName string) (string, error)
• func WaitForTermination(stopCh chan struct{}, wg *sync.WaitGroup)
• type APodRequest
  • func (req *APodRequest) PortForwardAPod() error

Functions

func GetPodFromService

func GetPodFromService(kubeClient *kubernetes.Clientset, namespace string, serviceName string) (string, error)

func WaitForTermination

func WaitForTermination(stopCh chan struct{}, wg *sync.WaitGroup)

Types

type APodRequest

type APodRequest struct {
	RestConfig *rest.Config
	Pod        v1.Pod
	LocalPort  int
	PodPort    int
	Streams    genericiooptions.IOStreams
	StopCh     <-chan struct{}
	ReadyCh    chan struct{}
}

func (*APodRequest) PortForwardAPod

func (req *APodRequest) PortForwardAPod() error