k8s

Documentation

Index

• Variables
• func GetContexts(kubeconfigPath string) ([]string, error)
• func GetNamespaces(kubeconfigPath string, ctx string) ([]string, error)
• func GetPVCs(kubeconfigPath string, ctx string, namespace string) ([]string, error)
• func GetServiceAddress(cli kubernetes.Interface, namespace string, name string, ...) (string, error)
• func PortForward(req *PortForwardRequest) error
• func WaitForJobCompletion(logger *log.Entry, cli kubernetes.Interface, namespace string, name string, ...) error
• func WaitForPod(cli kubernetes.Interface, namespace, labelSelector string) (*corev1.Pod, error)
• type ClusterClient
  • func GetClusterClient(kubeconfigPath string, context string) (*ClusterClient, error)
• type HelmRESTClientGetter
  • func NewRESTClientGetter(restConfig *rest.Config, clientConfig clientcmd.ClientConfig) *HelmRESTClientGetter
  • func (c *HelmRESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)
  • func (c *HelmRESTClientGetter) ToRESTConfig() (*rest.Config, error)
  • func (c *HelmRESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)
  • func (c *HelmRESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig
• type PortForwardRequest

Variables

var ErrJobFailed = errors.New("job failed")

var ErrUnexpectedTypePodWatch = errors.New("unexpected type while watching pods")

var ErrUnexpectedTypeServiceWatch = errors.New("unexpected type while watching service")

Functions

func GetContexts

func GetContexts(kubeconfigPath string) ([]string, error)

func GetNamespaces

func GetNamespaces(kubeconfigPath string, ctx string) ([]string, error)

func GetPVCs

func GetPVCs(kubeconfigPath string, ctx string, namespace string) ([]string, error)

func GetServiceAddress

func GetServiceAddress(
	cli kubernetes.Interface,
	namespace string,
	name string,
	lbTimeout time.Duration,
) (string, error)

func PortForward

func PortForward(req *PortForwardRequest) error

func WaitForJobCompletion

func WaitForJobCompletion(logger *log.Entry, cli kubernetes.Interface,
	namespace string, name string, progressBarRequested bool,
) error

func WaitForPod

func WaitForPod(cli kubernetes.Interface, namespace, labelSelector string) (*corev1.Pod, error)

Types

type ClusterClient

type ClusterClient struct {
	RestConfig       *rest.Config
	KubeClient       kubernetes.Interface
	RESTClientGetter genericclioptions.RESTClientGetter
	NsInContext      string
}

func GetClusterClient

func GetClusterClient(kubeconfigPath string, context string) (*ClusterClient, error)

type HelmRESTClientGetter

type HelmRESTClientGetter struct {
	// contains filtered or unexported fields
}

func NewRESTClientGetter

func NewRESTClientGetter(restConfig *rest.Config,
	clientConfig clientcmd.ClientConfig,
) *HelmRESTClientGetter

func (*HelmRESTClientGetter) ToDiscoveryClient

func (c *HelmRESTClientGetter) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

func (*HelmRESTClientGetter) ToRESTConfig

func (c *HelmRESTClientGetter) ToRESTConfig() (*rest.Config, error)

func (*HelmRESTClientGetter) ToRESTMapper

func (c *HelmRESTClientGetter) ToRESTMapper() (meta.RESTMapper, error)

func (*HelmRESTClientGetter) ToRawKubeConfigLoader

func (c *HelmRESTClientGetter) ToRawKubeConfigLoader() clientcmd.ClientConfig

type PortForwardRequest

type PortForwardRequest struct {
	// RestConfig is the kubernetes config
	RestConfig *rest.Config
	PodNs      string
	PodName    string
	LocalPort  int
	PodPort    int
	StopCh     <-chan struct{}
	ReadyCh    chan struct{}
	Logger     *log.Entry
}