Documentation
¶
Index ¶
- func DescribePod(namespace, name string) (string, 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 GetFirstRunningPod(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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DescribePod ¶ added in v0.2.0
DescribePod returns a desription string of a pod (internally calls the kubectl describe function)
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 ¶
GetClientConfig loads the configuration for kubernetes clients and parses it to *rest.Config
func GetFirstRunningPod ¶ added in v1.0.0
func GetFirstRunningPod(kubectl *kubernetes.Clientset, labelSelector, namespace string) (*k8sv1.Pod, error)
GetFirstRunningPod retrieves the first pod that is found that has the status "Running" using the label selector string
func GetPodStatus ¶ added in v0.2.0
GetPodStatus returns the pod status as a string Taken from https://github.com/kubernetes/kubernetes/pkg/printers/internalversion/printers.go
func GetPodsFromDeployment ¶ added in v0.2.0
func GetPodsFromDeployment(kubectl *kubernetes.Clientset, deployment, namespace string) (*k8sv1.PodList, error)
GetPodsFromDeployment retrieves all found pods from a deployment name
func IsMinikube ¶ added in v1.0.3
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
Types ¶
This section is empty.
Source Files