k8sutils

Documentation

Index

• func CreateKubeClientSet(kubeConfig string) (*kubernetes.Clientset, error)
• func LeaderElection(clientSet *kubernetes.Clientset, lockName string, namespace string, ...)
• type K8sUtils
  • func Init(kubeConfig string) (*K8sUtils, error)
  • func (c *K8sUtils) GetNodeIPs(nodeID string) string
  • func (c *K8sUtils) GetNodeLabels(nodeFullName string) (map[string]string, error)
• type KubernetesClient
• type UtilsInterface

Functions

func CreateKubeClientSet

func CreateKubeClientSet(kubeConfig string) (*kubernetes.Clientset, error)

CreateKubeClientSet - Returns kubeClient set

func LeaderElection

func LeaderElection(clientSet *kubernetes.Clientset, lockName string, namespace string, runFunc func(ctx context.Context))

LeaderElection ...

Types

type K8sUtils

type K8sUtils struct {
	KubernetesClient *KubernetesClient
}

K8sUtils stores the configuration of the k8s client, k8s client and the informer

func Init

func Init(kubeConfig string) (*K8sUtils, error)

Init - Initializes the k8s client and creates the secret informer

func (*K8sUtils) GetNodeIPs

func (c *K8sUtils) GetNodeIPs(nodeID string) string

GetNodeIPs returns cluster IP of the node object

func (*K8sUtils) GetNodeLabels

func (c *K8sUtils) GetNodeLabels(nodeFullName string) (map[string]string, error)

GetNodeLabels returns back Node labels for the node name

type KubernetesClient

type KubernetesClient struct {
	ClientSet *kubernetes.Clientset
}

KubernetesClient - client connection

type UtilsInterface

type UtilsInterface interface {
	GetNodeLabels(string) (map[string]string, error)
	GetNodeIPs(string) string
}

UtilsInterface - interface which provides helper methods related to k8s