k8s

Documentation

Index

• func NewErrorDrainIsLocked() error
• func NewErrorFailedToEvictAllPods() error
• type Client
  • func NewClient(kubeconfig string) (*Client, error)
  • func NewFakeClient() (*Client, *fake.Clientset)
  • func (c *Client) DrainNode(node string) error
  • func (c *Client) FindNodeByZincatiID(zincatiID string) (string, error)
  • func (c *Client) IsDrained(node string) (bool, error)
  • func (c *Client) UncordonNode(node string) error
• type ErrorDrainIsLocked
  • func (e ErrorDrainIsLocked) Error() string
• type ErrorFailedToEvictAllPods
  • func (e ErrorFailedToEvictAllPods) Error() string

Functions

func NewErrorDrainIsLocked

func NewErrorDrainIsLocked() error

func NewErrorFailedToEvictAllPods

func NewErrorFailedToEvictAllPods() error

Types

type Client

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

func NewClient

func NewClient(kubeconfig string) (*Client, error)

Create a new kubernetes client, defaults to in-cluster if no kubeconfig is provided

func NewFakeClient

func NewFakeClient() (*Client, *fake.Clientset)

Create a test client with a fake kubernetes clientset

func (*Client) DrainNode

func (c *Client) DrainNode(node string) error

Drain a node from all pods and set it to unschedulable. Status will be tracked in lease, only one drain will be run at a time.

func (*Client) FindNodeByZincatiID

func (c *Client) FindNodeByZincatiID(zincatiID string) (string, error)

Find the node in the cluster with the matching machine id

func (*Client) IsDrained

func (c *Client) IsDrained(node string) (bool, error)

Check if a node has been drained

func (*Client) UncordonNode

func (c *Client) UncordonNode(node string) error

Uncordon a node

type ErrorDrainIsLocked

type ErrorDrainIsLocked struct{}

func (ErrorDrainIsLocked) Error

func (e ErrorDrainIsLocked) Error() string

type ErrorFailedToEvictAllPods

type ErrorFailedToEvictAllPods struct{}

func (ErrorFailedToEvictAllPods) Error

func (e ErrorFailedToEvictAllPods) Error() string