k8sapi

func CheckAPIServerConnectivity ¶ added in v1.8.0

func CheckAPIServerConnectivity() error

func CreateKubeClient ¶

func CreateKubeClient(appName string) (client.Client, error)

CreateKubeClient creates a k8s client

func CreateKubeClientCache ¶ added in v1.15.0

func CreateKubeClientCache(restCfg *rest.Config, scheme *runtime.Scheme, filterMap map[client.Object]cache.ByObject) (cache.Cache, error)

Create cache reader for Kubernetes client

func GetKubeClientSet ¶ added in v1.8.0

func GetKubeClientSet() (kubernetes.Interface, error)

func GetNode ¶ added in v1.13.0

func GetNode(ctx context.Context, k8sClient client.Client) (corev1.Node, error)

func StartKubeClientCache ¶ added in v1.15.0

func StartKubeClientCache(cache cache.Cache)