kubernetes

Documentation

Index

• Variables
• func GetContainers(pod *corev1.Pod) []string
• type Client
  • func GetClient() *Client
  • func (client Client) GetDaemonsetFromPod(pod *corev1.Pod) (*v1.DaemonSet, error)
  • func (client Client) GetDeloymentFromPod(pod *corev1.Pod) (*v1.ReplicaSet, error)
  • func (client Client) GetPod(pod, namespace string) (*corev1.Pod, error)
  • func (client Client) GetReplicasetFromPod(pod *corev1.Pod) (*v1.ReplicaSet, error)
  • func (client Client) GetStatefulsetFromPod(pod *corev1.Pod) (*v1.StatefulSet, error)

Variables

var CheckPodExist = func(event *events.Event) error {
	if err := checks.CheckPodName(event); err != nil {
		return err
	}
	if err := checks.CheckNamespace(event); err != nil {
		return err
	}

	if _, err := client.GetPod(event.GetPodName(), event.GetNamespaceName()); err == nil {
		return err
	}
	return nil
}

var Init = func() error {
	client = new(Client)
	config := configuration.GetConfiguration()
	var err error
	if config.KubeConfig != "" {
		client.RestConfig, err = clientcmd.BuildConfigFromFlags("", config.KubeConfig)
	} else {
		client.RestConfig, err = rest.InClusterConfig()
	}
	if err != nil {
		return err
	}

	client.Clientset, err = k8s.NewForConfig(client.RestConfig)
	if err != nil {
		return err
	}
	return nil
}

Functions

func GetContainers

func GetContainers(pod *corev1.Pod) []string

Types

type Client

type Client struct {
	*k8s.Clientset
	RestConfig *rest.Config
}

func GetClient

func GetClient() *Client

func (Client) GetDaemonsetFromPod

func (client Client) GetDaemonsetFromPod(pod *corev1.Pod) (*v1.DaemonSet, error)

func (Client) GetDeloymentFromPod

func (client Client) GetDeloymentFromPod(pod *corev1.Pod) (*v1.ReplicaSet, error)

func (Client) GetPod

func (client Client) GetPod(pod, namespace string) (*corev1.Pod, error)

func (Client) GetReplicasetFromPod

func (client Client) GetReplicasetFromPod(pod *corev1.Pod) (*v1.ReplicaSet, error)

func (Client) GetStatefulsetFromPod

func (client Client) GetStatefulsetFromPod(pod *corev1.Pod) (*v1.StatefulSet, error)