k8sutil

Documentation

Index

• func PodRunningAndReady(pod v1.Pod) (bool, error)
• func ResolveKubectlBinary(kubeclient *kubernetes.Clientset) (string, error)
• func V1BetaSelectorToListOptions(selector *v1beta1.LabelSelector) (*api.ListOptions, error)
• func WaitForTPRReady(restClient *rest.RESTClient, tprGroup, tprVersion, tprName string) error
• type PodAction
  • func (p *PodAction) CheckLatestPod()
  • func (p *PodAction) WatchLoop() error
  • func (p *PodAction) WatchPods(kubeclient *kubernetes.Clientset, namespace string, listOpts *api.ListOptions) cache.SharedIndexInformer
• type PodFunc

Functions

func PodRunningAndReady

func PodRunningAndReady(pod v1.Pod) (bool, error)

PodRunningAndReady returns whether a pod is running and each container has passed it's ready state.

func ResolveKubectlBinary

func ResolveKubectlBinary(kubeclient *kubernetes.Clientset) (string, error)

ResolveKubectlBinary resolves the binary to use such as 'kubectl' or 'oc'

func V1BetaSelectorToListOptions

func V1BetaSelectorToListOptions(selector *v1beta1.LabelSelector) (*api.ListOptions, error)

V1BetaSelectorToListOptions converts a selector from a Deployment to an api.ListOptions object

func WaitForTPRReady

func WaitForTPRReady(restClient *rest.RESTClient, tprGroup, tprVersion, tprName string) error

WaitForTPRReady waits for a third party resource to be available for use.

Types

type PodAction

type PodAction struct {
	OnPodChange PodFunc
	// contains filtered or unexported fields
}

func (*PodAction) CheckLatestPod

func (p *PodAction) CheckLatestPod()

func (*PodAction) WatchLoop

func (p *PodAction) WatchLoop() error

WatchLoop is the loop waiting or the watch to fail

func (*PodAction) WatchPods

func (p *PodAction) WatchPods(kubeclient *kubernetes.Clientset, namespace string, listOpts *api.ListOptions) cache.SharedIndexInformer

WatchPods sets up the watcher for the given kubernetes client, namespace and listOpts

type PodFunc

type PodFunc func(pod *v1.Pod) error