kubernetes

Documentation

Index

• func GetClient() (*kubernetes.Clientset, error)
• func GetRestConfig() (*rest.Config, error)
• func WaitForPodComplete(ctx context.Context, clientset *kubernetes.Clientset, ...) error
• func WaitForPodInitialized(ctx context.Context, clientset *kubernetes.Clientset, ...) error
• type Copy
  • func (c Copy) CopyFileIntoPod(client *kubernetes.Clientset) error
• type Exec
  • func (e Exec) Exec(client *kubernetes.Clientset) error

Functions

func GetClient

func GetClient() (*kubernetes.Clientset, error)

GetClient creates a new kubernetes client with the kubeconfig at ~/.kube/config

func GetRestConfig

func GetRestConfig() (*rest.Config, error)

GetRestConfig returns a new rest.Config based on the kubeconfig at ~/.kube/config

func WaitForPodComplete

func WaitForPodComplete(ctx context.Context, clientset *kubernetes.Clientset, namespace, podName string, finish chan bool) error

WaitForPodComplete waits for a specific pod to be in complete state

func WaitForPodInitialized

func WaitForPodInitialized(ctx context.Context, clientset *kubernetes.Clientset, namespace, podName string) error

WaitForPodInitialized waits for a specific pod to be initialized

Types

type Copy

type Copy struct {
	Namespace string
	PodName   string
	Container string
	SrcPath   string
	DestPath  string
}

Copy contains all required information to copy a file into a pod

func (Copy) CopyFileIntoPod

func (c Copy) CopyFileIntoPod(client *kubernetes.Clientset) error

CopyFileIntoPod copies the src .tar.gz into the specified container

type Exec

type Exec struct {
	Namespace string
	PodName   string
	Container string

	Command []string
	Stdin   io.Reader
	Stdout  io.Writer
	Stderr  io.Writer
}

Exec contains all required information to execute a command in a container

func (Exec) Exec

func (e Exec) Exec(client *kubernetes.Clientset) error

Exec executes a command in the specified container and opens a websocket stream if needed for Stdin