proxy

Documentation

Index

• func Listen(ctx context.Context, clientset kubernetes.Interface, restConfig *rest.Config, ...) (net.Listener, error)
• type Addr
  • func (a Addr) Network() string
  • func (a Addr) String() string
• type PodDirIO
  • func (p PodDirIO) CreateFile(path string, content io.Reader) error
  • func (p PodDirIO) DirExists(path string) (bool, error)
  • func (p PodDirIO) Mkdir(path string) error
  • func (p PodDirIO) RemoveAll(path string) error
  • func (p PodDirIO) Rename(oldPath, newPath string) error

Functions

func Listen

func Listen(ctx context.Context, clientset kubernetes.Interface, restConfig *rest.Config, addr Addr) (net.Listener, error)

Listen creates a listener which returns new connections whenever someone connects to a socat or mock driver proxy instance running inside the given pod.

socat must by started with "<listen>,fork TCP-LISTEN:<port>,reuseport" for this to work. "<listen>" can be anything that accepts connections, for example "UNIX-LISTEN:/csi/csi.sock". In this mode, socat will accept exactly one connection on the given port for each connection that socat itself accepted.

Listening stops when the context is done or Close() is called.

Types

type Addr

type Addr struct {
	Namespace, PodName, ContainerName string
	Port                              int
}

Addr contains all relevant parameters for a certain port in a pod. The container must be running before connections are attempted.

func (Addr) Network

func (a Addr) Network() string

func (Addr) String

func (a Addr) String() string

type PodDirIO

type PodDirIO struct {
	F             *framework.Framework
	Namespace     string
	PodName       string
	ContainerName string
	Logger        *klog.Logger
}

func (PodDirIO) CreateFile

func (p PodDirIO) CreateFile(path string, content io.Reader) error

func (PodDirIO) DirExists

func (p PodDirIO) DirExists(path string) (bool, error)

func (PodDirIO) Mkdir

func (p PodDirIO) Mkdir(path string) error

func (PodDirIO) RemoveAll

func (p PodDirIO) RemoveAll(path string) error

func (PodDirIO) Rename

func (p PodDirIO) Rename(oldPath, newPath string) error