kubernetes

Documentation

Index

• func Contains(nodes []v1.Node, n *v1.Node) bool
• type Client
  • func NewClient(kubeConfig string) (*Client, error)
  • func (c *Client) CordonNode(node *v1.Node) (*v1.Node, error)
  • func (c *Client) DeletePod(pod v1.Pod, deleteOptions *metav1.DeleteOptions) error
  • func (c *Client) DetermineNewPod(oldPod v1.Pod) (*v1.Pod, error)
  • func (c *Client) GetNode(nodeName string) (*v1.Node, error)
  • func (c *Client) GetPodsOnNode(nodeName string) (*v1.PodList, error)
  • func (c *Client) GetPodsWithLabel(label, namespace string) (*v1.PodList, error)
  • func (c *Client) IdentifyNewNode(nodes []v1.Node, instanceGroup string) (*v1.Node, error)
  • func (c *Client) ListNodes() (*v1.NodeList, error)
  • func (c *Client) WaitForNewNodeToBeReady(node *v1.Node) error
  • func (c *Client) WaitForNodeToTerminate(node v1.Node) error
  • func (c *Client) WaitForPodToBeReady(pod *v1.Pod) error

Functions

func Contains

func Contains(nodes []v1.Node, n *v1.Node) bool

Types

type Client

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

func NewClient

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

NewKubernets creates a new container with kubeclient, and the generic flags

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

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

func (*Client) ListNodes

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

GetNode finds the node in the cluster

func (*Client) WaitForNewNodeToBeReady

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

func (*Client) WaitForNodeToTerminate

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

func (*Client) WaitForPodToBeReady

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