kubectl

Documentation

Index

• Constants
• func DescribePod(namespace, name string) (string, error)
• func EnsureDefaultNamespace(client *kubernetes.Clientset, log log.Logger) error
• func EnsureGoogleCloudClusterRoleBinding(client *kubernetes.Clientset, log log.Logger) error
• func Exec(kubectlClient *kubernetes.Clientset, pod *k8sv1.Pod, container string, ...) (io.WriteCloser, io.ReadCloser, io.ReadCloser, error)
• func ExecBuffered(kubectlClient *kubernetes.Clientset, pod *k8sv1.Pod, container string, ...) ([]byte, []byte, error)
• func ForwardPorts(kubectlClient *kubernetes.Clientset, pod *k8sv1.Pod, ports []string, ...) error
• func GetClientConfig() (*rest.Config, error)
• func GetNewestRunningPod(kubectl *kubernetes.Clientset, labelSelector, namespace string) (*k8sv1.Pod, error)
• func GetPodStatus(pod *k8sv1.Pod) string
• func GetPodsFromDeployment(kubectl *kubernetes.Clientset, deployment, namespace string) (*k8sv1.PodList, error)
• func IsMinikube() bool
• func NewClient() (*kubernetes.Clientset, error)
• func NewClientWithContextSwitch(switchContext bool) (*kubernetes.Clientset, error)

Constants

const ClusterRoleBindingName = "devspace-users"

ClusterRoleBindingName is the name of the cluster role binding that ensures that the user has enough rights

Functions

func DescribePod

func DescribePod(namespace, name string) (string, error)

DescribePod returns a desription string of a pod (internally calls the kubectl describe function)

func EnsureDefaultNamespace

func EnsureDefaultNamespace(client *kubernetes.Clientset, log log.Logger) error

EnsureDefaultNamespace makes sure the default namespace exists or will be created

func EnsureGoogleCloudClusterRoleBinding

func EnsureGoogleCloudClusterRoleBinding(client *kubernetes.Clientset, log log.Logger) error

EnsureGoogleCloudClusterRoleBinding makes sure the needed cluster role is created in the google cloud or a warning is printed

func Exec

func Exec(kubectlClient *kubernetes.Clientset, pod *k8sv1.Pod, container string, command []string, tty bool, errorChannel chan<- error) (io.WriteCloser, io.ReadCloser, io.ReadCloser, error)

Exec executes a command for kubectl

func ExecBuffered

func ExecBuffered(kubectlClient *kubernetes.Clientset, pod *k8sv1.Pod, container string, command []string) ([]byte, []byte, error)

ExecBuffered executes a command for kubernetes and returns the output and error buffers

func ForwardPorts

func ForwardPorts(kubectlClient *kubernetes.Clientset, pod *k8sv1.Pod, ports []string, stopChan chan struct{}, readyChan chan struct{}) error

ForwardPorts forwards the specified ports from the cluster to the local machine

func GetClientConfig

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

GetClientConfig loads the configuration for kubernetes clients and parses it to *rest.Config

func GetNewestRunningPod

func GetNewestRunningPod(kubectl *kubernetes.Clientset, labelSelector, namespace string) (*k8sv1.Pod, error)

GetNewestRunningPod retrieves the first pod that is found that has the status "Running" using the label selector string

func GetPodStatus

func GetPodStatus(pod *k8sv1.Pod) string

GetPodStatus returns the pod status as a string Taken from https://github.com/kubernetes/kubernetes/pkg/printers/internalversion/printers.go

func GetPodsFromDeployment

func GetPodsFromDeployment(kubectl *kubernetes.Clientset, deployment, namespace string) (*k8sv1.PodList, error)

GetPodsFromDeployment retrieves all found pods from a deployment name

func IsMinikube

func IsMinikube() bool

IsMinikube returns true if the Kubernetes cluster is a minikube

func NewClient

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

NewClient creates a new kubernetes client

func NewClientWithContextSwitch

func NewClientWithContextSwitch(switchContext bool) (*kubernetes.Clientset, error)

NewClientWithContextSwitch creates a new kubernetes client and switches the kubectl context