kubernetes

Documentation

Index

• Constants
• func IsRetryableError(err error) bool
• type Client
  • func NewClientFromKubeletKubeconfig() (*Client, error)
  • func NewClientFromPKI(ca, crt, key []byte, endpoint *url.URL) (*Client, error)
  • func NewForConfig(config *restclient.Config) (*Client, error)
  • func NewTemporaryClientControlPlane(ctx context.Context, r controller.Reader) (client *Client, err error)
  • func NewTemporaryClientFromPKI(ca *x509.PEMEncodedCertificateAndKey, endpoint *url.URL) (client *Client, err error)
  • func (h *Client) Cordon(ctx context.Context, name string) error
  • func (h *Client) CordonAndDrain(ctx context.Context, node string) (err error)
  • func (h *Client) Drain(ctx context.Context, node string) error
  • func (h *Client) LabelNodeAsControlPlane(ctx context.Context, name string, taintNoSchedule bool) (err error)
  • func (h *Client) NodeIPs(ctx context.Context, machineType machine.Type) (addrs []string, err error)
  • func (h *Client) Uncordon(ctx context.Context, name string, force bool) error
  • func (h *Client) WaitUntilReady(ctx context.Context, name string) error

Constants

const (
	// DrainTimeout is maximum time to wait for the node to be drained.
	DrainTimeout = 5 * time.Minute
)

Functions

func IsRetryableError

func IsRetryableError(err error) bool

IsRetryableError returns true if this Kubernetes API should be retried.

Types

type Client

type Client struct {
	*taloskubernetes.Client
}

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

func NewClientFromKubeletKubeconfig

func NewClientFromKubeletKubeconfig() (*Client, error)

NewClientFromKubeletKubeconfig initializes and returns a Client.

func NewClientFromPKI

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

NewClientFromPKI initializes and returns a Client.

func NewForConfig

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

NewForConfig initializes and returns a client using the provided config.

func NewTemporaryClientControlPlane

func NewTemporaryClientControlPlane(ctx context.Context, r controller.Reader) (client *Client, err error)

NewTemporaryClientControlPlane initializes a Kubernetes client for a controlplane node using PKI information.

The client uses "localhost" endpoint, so it doesn't depend on the loadbalancer to be ready.

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(ctx context.Context, name string) error

Cordon marks a node as unschedulable.

func (*Client) CordonAndDrain

func (h *Client) CordonAndDrain(ctx context.Context, node string) (err error)

CordonAndDrain cordons and drains a node in one call.

func (*Client) Drain

func (h *Client) Drain(ctx context.Context, node string) error

Drain evicts all pods on a given node.

func (*Client) LabelNodeAsControlPlane

func (h *Client) LabelNodeAsControlPlane(ctx context.Context, name string, taintNoSchedule bool) (err error)

LabelNodeAsControlPlane labels a node with the required control-plane label and NoSchedule taint.

func (*Client) NodeIPs

func (h *Client) NodeIPs(ctx context.Context, machineType machine.Type) (addrs []string, err error)

NodeIPs returns list of node IP addresses by machine type.

func (*Client) Uncordon

func (h *Client) Uncordon(ctx context.Context, 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(ctx context.Context, name string) error

WaitUntilReady waits for a node to be ready.