Documentation
¶
Index ¶
- Constants
- func IsRetryableError(err error) bool
- func NewDialer() *connrotation.Dialer
- 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) Close() 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) LabelNodeAsMaster(ctx context.Context, name string, taintNoSchedule bool) (err error)
- func (h *Client) MasterIPs(ctx context.Context) (addrs []string, 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 )
Variables ¶
This section is empty.
Functions ¶
func IsRetryableError ¶ added in v0.10.0
IsRetryableError returns true if this Kubernetes API should be retried.
func NewDialer ¶ added in v0.14.0
func NewDialer() *connrotation.Dialer
NewDialer creates new custom dialer.
Types ¶
type Client ¶ added in v0.3.0
type Client struct { *kubernetes.Clientset // contains filtered or unexported fields }
Client represents a set of helper methods for interacting with the Kubernetes API.
func NewClientFromKubeletKubeconfig ¶ added in v0.3.0
NewClientFromKubeletKubeconfig initializes and returns a Client.
func NewClientFromPKI ¶ added in v0.3.0
NewClientFromPKI initializes and returns a Client.
func NewForConfig ¶ added in v0.3.0
func NewForConfig(config *restclient.Config) (client *Client, err error)
NewForConfig initializes and returns a client using the provided config.
func NewTemporaryClientFromPKI ¶ added in v0.3.0
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) CordonAndDrain ¶ added in v0.3.0
CordonAndDrain cordons and drains a node in one call.
func (*Client) LabelNodeAsMaster ¶ added in v0.3.0
func (h *Client) LabelNodeAsMaster(ctx context.Context, name string, taintNoSchedule bool) (err error)
LabelNodeAsMaster labels a node with the required master label and NoSchedule taint.
func (*Client) MasterIPs ¶ added in v0.3.0
MasterIPs returns a list of control plane endpoints (IP addresses).