pod

Documentation

Index

• func Logs(ctx context.Context, client kubernetes.Interface, ...) (output string, err error)
• func NewTransport(logger logr.Logger, client kubernetes.Interface, restConfig *rest.Config) *http.Transport
• func RunInPod(f *framework.Framework, rootdir string, files []string, command string, ...) (string, string)
• type Addr
  • func ParseAddr(addr string) (*Addr, error)
  • func (a Addr) Network() string
  • func (a Addr) String() string
• type Dialer
  • func NewDialer(client kubernetes.Interface, restConfig *rest.Config) *Dialer
  • func (d *Dialer) DialContainerPort(ctx context.Context, addr Addr) (conn net.Conn, finalErr error)
• type LocalAddr
  • func (l LocalAddr) Network() string
  • func (l LocalAddr) String() string

Functions

func Logs

func Logs(ctx context.Context, client kubernetes.Interface, namespace, pod, container string) (output string, err error)

Retrieves a container log, with retry in case of errors. It is okay if the pod does not exist yet.

func NewTransport

func NewTransport(logger logr.Logger, client kubernetes.Interface, restConfig *rest.Config) *http.Transport

NewTransport creates a transport which uses the port forward dialer. URLs must use <namespace>.<pod>:<port> as host.

func RunInPod

func RunInPod(f *framework.Framework, rootdir string, files []string, command string, namespace, pod, container string) (string, string)

RunInPod optionally transfers some files into /tmp (source file relative to root dir, with same base file name, without path, with same x bit) and executes a shell command. Any error is treated as test failure.

Relies on dd in the target container.

Types

type Addr

type Addr struct {
	Namespace, PodName string
	Port               int
}

Addr contains all relevant parameters for a certain port in a pod. The container should be running before connections are attempted, otherwise the connection will fail.

func ParseAddr

func ParseAddr(addr string) (*Addr, error)

func (Addr) Network

func (a Addr) Network() string

func (Addr) String

func (a Addr) String() string

type Dialer

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

Dialer holds the relevant parameters that are independent of a particular connection.

func NewDialer

func NewDialer(client kubernetes.Interface, restConfig *rest.Config) *Dialer

NewDialer creates a dialer that supports connecting to container ports.

func (*Dialer) DialContainerPort

func (d *Dialer) DialContainerPort(ctx context.Context, addr Addr) (conn net.Conn, finalErr error)

DialContainerPort connects to a certain container port in a pod.

type LocalAddr

type LocalAddr struct{}

func (LocalAddr) Network

func (l LocalAddr) Network() string

func (LocalAddr) String

func (l LocalAddr) String() string