connect

Documentation

Index

• func GetFreePort() (int, error)
• func StartTunnel(restConfig *restclient.Config, podName string, namspace string, ports []string, ...) error
• func TunnelForEachPod(ctx context.Context, config *rest.Config, clientset *kubernetes.Clientset, ...) error
• func TunnelForPod(ctx context.Context, config *rest.Config, pod *corev1.Pod, port int, ...) error
• type Option
  • func WithIOStreams(streams *genericclioptions.IOStreams) Option
  • func WithReadyChannel(readyCh chan struct{}) Option
  • func WithStopChannel(stopCh <-chan struct{}) Option

Functions

func GetFreePort

func GetFreePort() (int, error)

func StartTunnel

func StartTunnel(restConfig *restclient.Config, podName string, namspace string, ports []string, opts ...Option) error

StartTunnel starts tunnel to podName in namspace on the listed ports (8080:8080 etc.)

func TunnelForEachPod

func TunnelForEachPod(ctx context.Context, config *rest.Config, clientset *kubernetes.Clientset, object runtime.Object, port int, handle tunnelHandler) error

func TunnelForPod

func TunnelForPod(ctx context.Context, config *rest.Config, pod *corev1.Pod, port int, handle tunnelHandler) error

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithIOStreams

func WithIOStreams(streams *genericclioptions.IOStreams) Option

func WithReadyChannel

func WithReadyChannel(readyCh chan struct{}) Option

func WithStopChannel

func WithStopChannel(stopCh <-chan struct{}) Option