kubernetes

Documentation

Index

• type Client
  • func NewClientFromKubeletKubeconfig() (client *Client, err error)
  • func NewClientFromPKI(ca, crt, key []byte, endpoint *url.URL) (client *Client, err error)
  • func NewForConfig(config *restclient.Config) (client *Client, err error)
  • func NewTemporaryClientFromPKI(ca *x509.PEMEncodedCertificateAndKey, endpoint *url.URL) (client *Client, err error)
  • func (h *Client) Cordon(name string) error
  • func (h *Client) CordonAndDrain(node string) (err error)
  • func (h *Client) Drain(node string) error
  • func (h *Client) LabelNodeAsMaster(name string, taintNoSchedule bool) (err error)
  • func (h *Client) MasterIPs(ctx context.Context) (addrs []string, err error)
  • func (h *Client) Uncordon(name string, force bool) error
  • func (h *Client) WaitUntilReady(name string) error
  • func (h *Client) WorkerIPs(ctx context.Context) (addrs []string, err error)

Types

type Client

type Client struct {
	*kubernetes.Clientset
}

Client represents a set of helper methods for interacting with the Kubernetes API.

func NewClientFromKubeletKubeconfig

func NewClientFromKubeletKubeconfig() (client *Client, err error)

NewClientFromKubeletKubeconfig initializes and returns a Client.

func NewClientFromPKI

func NewClientFromPKI(ca, crt, key []byte, endpoint *url.URL) (client *Client, err error)

NewClientFromPKI initializes and returns a Client.

nolint: interfacer

func NewForConfig

func NewForConfig(config *restclient.Config) (client *Client, err error)

NewForConfig initializes and returns a client using the provided config.

func NewTemporaryClientFromPKI

func NewTemporaryClientFromPKI(ca *x509.PEMEncodedCertificateAndKey, endpoint *url.URL) (client *Client, err error)

NewTemporaryClientFromPKI initializes a Kubernetes client using a certificate with a TTL of 10 minutes.

func (*Client) Cordon

func (h *Client) Cordon(name string) error

Cordon marks a node as unschedulable.

func (*Client) CordonAndDrain

func (h *Client) CordonAndDrain(node string) (err error)

CordonAndDrain cordons and drains a node in one call.

func (*Client) Drain

func (h *Client) Drain(node string) error

Drain evicts all pods on a given node.

func (*Client) LabelNodeAsMaster

func (h *Client) LabelNodeAsMaster(name string, taintNoSchedule bool) (err error)

LabelNodeAsMaster labels a node with the required master label and NoSchedule taint.

nolint: gocyclo

func (*Client) MasterIPs

func (h *Client) MasterIPs(ctx context.Context) (addrs []string, err error)

MasterIPs returns a list of control plane endpoints (IP addresses).

func (*Client) Uncordon

func (h *Client) Uncordon(name string, force bool) error

Uncordon marks a node as schedulable.

If force is set, node will be uncordoned even if cordoned not by Talos.

func (*Client) WaitUntilReady

func (h *Client) WaitUntilReady(name string) error

WaitUntilReady waits for a node to be ready.

func (*Client) WorkerIPs

func (h *Client) WorkerIPs(ctx context.Context) (addrs []string, err error)

WorkerIPs returns list of worker nodes IP addresses.