kubernetes

Documentation

Index

• type Client
  • func NewClient(kubeConfig string) (*Client, error)
  • func (c *Client) CordonNode(ctx context.Context, node *v1.Node) (*v1.Node, error)
  • func (c *Client) DeletePod(ctx context.Context, pod v1.Pod, deleteOptions metav1.DeleteOptions) error
  • func (c *Client) Deployments(ctx context.Context) (*appv1.DeploymentList, error)
  • func (c *Client) DetermineNewPod(ctx context.Context, oldPod v1.Pod) (*v1.Pod, error)
  • func (c *Client) Node(ctx context.Context, nodeName string) (*v1.Node, error)
  • func (c *Client) Nodes(ctx context.Context, labelSelector fields.Selector) (*v1.NodeList, error)
  • func (c *Client) PodsOnNode(ctx context.Context, nodeName string) (*v1.PodList, error)
  • func (c *Client) StatefulSets(ctx context.Context) (*appv1.StatefulSetList, error)
  • func (c *Client) UpdateDeployment(ctx context.Context, d *appv1.Deployment) error
  • func (c *Client) UpdateStatefulSet(ctx context.Context, s *appv1.StatefulSet) error
  • func (c *Client) WaitForPodToBeReady(ctx context.Context, pod *v1.Pod) error

Types

type Client

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

func NewClient

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

func (*Client) CordonNode

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

func (*Client) DeletePod

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

func (*Client) Deployments

func (c *Client) Deployments(ctx context.Context) (*appv1.DeploymentList, error)

func (*Client) DetermineNewPod

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

func (*Client) Node

func (c *Client) Node(ctx context.Context, nodeName string) (*v1.Node, error)

func (*Client) Nodes

func (c *Client) Nodes(ctx context.Context, labelSelector fields.Selector) (*v1.NodeList, error)

func (*Client) PodsOnNode

func (c *Client) PodsOnNode(ctx context.Context, nodeName string) (*v1.PodList, error)

func (*Client) StatefulSets

func (c *Client) StatefulSets(ctx context.Context) (*appv1.StatefulSetList, error)

func (*Client) UpdateDeployment

func (c *Client) UpdateDeployment(ctx context.Context, d *appv1.Deployment) error

func (*Client) UpdateStatefulSet

func (c *Client) UpdateStatefulSet(ctx context.Context, s *appv1.StatefulSet) error

func (*Client) WaitForPodToBeReady

func (c *Client) WaitForPodToBeReady(ctx context.Context, pod *v1.Pod) error