kubernetes

func (*Client) CordonNode ¶

func (c *Client) CordonNode(node *v1.Node) (*v1.Node, error)

CordonNode makes the node unschedulable

func (*Client) DeletePod ¶

func (c *Client) DeletePod(pod v1.Pod, deleteOptions *metav1.DeleteOptions) error

func (*Client) DetermineNewPod ¶

func (c *Client) DetermineNewPod(oldPod v1.Pod) (*v1.Pod, error)

func (*Client) GetNode ¶

func (c *Client) GetNode(nodeName string) (*v1.Node, error)

GetNode finds the node in the cluster

func (*Client) GetPodsOnNode ¶

func (c *Client) GetPodsOnNode(nodeName string) (*v1.PodList, error)

GetPodsOnNode returns all pods running on the specific node

func (*Client) GetPodsWithLabel ¶

func (c *Client) GetPodsWithLabel(label, namespace string) (*v1.PodList, error)

GetPodsWithLabel return all pods with the specified label

func (*Client) IdentifyNewNode ¶ added in v0.0.3

func (c *Client) IdentifyNewNode(nodes []v1.Node, instanceGroup string) (*v1.Node, error)

func (*Client) ListNodes ¶ added in v0.0.3

func (c *Client) ListNodes() (*v1.NodeList, error)

GetNode finds the node in the cluster

func (*Client) WaitForNewNodeToBeReady ¶ added in v0.0.3

func (c *Client) WaitForNewNodeToBeReady(node *v1.Node) error

func (*Client) WaitForNodeToTerminate ¶ added in v0.0.3

func (c *Client) WaitForNodeToTerminate(node v1.Node) error

func (*Client) WaitForPodToBeReady ¶

func (c *Client) WaitForPodToBeReady(pod *v1.Pod) error