k8sclient

Documentation

Index

• Variables
• type K8sClient
  • func NewK8sClient() (*K8sClient, error)
  • func (c *K8sClient) CordonNode(node *corev1.Node) error
  • func (c *K8sClient) DeleteNode(nodeName string) error
  • func (c *K8sClient) DrainNode(node *corev1.Node) error
  • func (c *K8sClient) GetNodes() NodeMap
  • func (c *K8sClient) GetServerVersion() (*version.Info, error)
  • func (c *K8sClient) SetNodeRoles(node *corev1.Node) error
  • func (c *K8sClient) WaitUntilNoPodsPending() error
  • func (c *K8sClient) WaitUntilNodeReady(nodeName string) (*corev1.Node, error)
• type NodeMap

Variables

var ErrTransientDrain = errors.New("server unable to handle drain request")

Types

type K8sClient

type K8sClient struct {
	Client *kubernetes.Clientset

	Drainer *drain.Helper
	// contains filtered or unexported fields
}

Kubernetes client

func NewK8sClient

func NewK8sClient() (*K8sClient, error)

func (*K8sClient) CordonNode

func (c *K8sClient) CordonNode(node *corev1.Node) error

func (*K8sClient) DeleteNode

func (c *K8sClient) DeleteNode(nodeName string) error

func (*K8sClient) DrainNode

func (c *K8sClient) DrainNode(node *corev1.Node) error

func (*K8sClient) GetNodes

func (c *K8sClient) GetNodes() NodeMap

func (*K8sClient) GetServerVersion

func (c *K8sClient) GetServerVersion() (*version.Info, error)

func (*K8sClient) SetNodeRoles

func (c *K8sClient) SetNodeRoles(node *corev1.Node) error

func (*K8sClient) WaitUntilNoPodsPending

func (c *K8sClient) WaitUntilNoPodsPending() error

func (*K8sClient) WaitUntilNodeReady

func (c *K8sClient) WaitUntilNodeReady(nodeName string) (*corev1.Node, error)

type NodeMap

type NodeMap map[string]*corev1.Node

map of NodeName->Node