flytek8s

Documentation

Overview

Collection of shared utils for initializing kubernetes clients within flyteadmin.

Index

• func GetRestClientConfig(kubeConfig, master string, k8sCluster *runtimeInterfaces.ClusterConfig) (*restclient.Config, error)
• func GetRestClientConfigForCluster(cluster runtimeInterfaces.ClusterConfig) (*restclient.Config, error)
• func NewKubeClient(kubeConfig, master string, k8sCluster *runtimeInterfaces.ClusterConfig) (client.Client, error)
• func RemoteClusterConfig(host string, auth runtimeInterfaces.Auth) (*restclient.Config, error)

Functions

func GetRestClientConfig

func GetRestClientConfig(kubeConfig, master string,
	k8sCluster *runtimeInterfaces.ClusterConfig) (*restclient.Config, error)

Initializes a config using a variety of configurable or default fallback options that can be passed to a Kubernetes client on initialization.

func GetRestClientConfigForCluster

func GetRestClientConfigForCluster(cluster runtimeInterfaces.ClusterConfig) (*restclient.Config, error)

func NewKubeClient

func NewKubeClient(kubeConfig, master string, k8sCluster *runtimeInterfaces.ClusterConfig) (client.Client, error)

Initializes a kubernetes Client which performs CRD operations on Kubernetes objects

func RemoteClusterConfig

func RemoteClusterConfig(host string, auth runtimeInterfaces.Auth) (*restclient.Config, error)

Reads secret values from paths specified in the config to initialize a Kubernetes rest client Config.