kube

Documentation

Index

• type KubeClient
  • func NewKubeClient(kubeconfig string) (*KubeClient, error)
  • func (k *KubeClient) DrainNode(ctx context.Context) error
  • func (k *KubeClient) FindDashboardAdminSecret() string
  • func (k *KubeClient) FindService(serviceName string) (string, int32)
  • func (k *KubeClient) WaitForNode(ctx context.Context) error

Types

type KubeClient

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

KubeClient abstracts operations on a running kubernetes cluster

func NewKubeClient

func NewKubeClient(kubeconfig string) (*KubeClient, error)

NewKubeClient creates a KubeClient object, configuring it from the provided kubeconfig. The connection will be established in this function

func (*KubeClient) DrainNode

func (k *KubeClient) DrainNode(ctx context.Context) error

DrainNode drains a node, that is stopping all pods on it

func (*KubeClient) FindDashboardAdminSecret

func (k *KubeClient) FindDashboardAdminSecret() string

func (*KubeClient) FindService

func (k *KubeClient) FindService(serviceName string) (string, int32)

func (*KubeClient) WaitForNode

func (k *KubeClient) WaitForNode(ctx context.Context) error

WaitForNode delays execution until a single node exists and is in state 'Ready', removing the unschedulable taint if possible