kubernetes

package

v1.14.1 Latest Latest Go to latest Published: Sep 15, 2026 License: MPL-2.0 Imports: 31 Imported by: 3

Details

View Source

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

This section is empty.

func IsRetryableError(err error) bool

IsRetryableError returns true if this Kubernetes API should be retried.

func VersionFromImageRef(image string) (string, bool)

VersionFromImageRef extracts the tag out of the image reference, ignoring the digest (if present).

It returns false if the reference can't be parsed or if the tag is missing.

func VersionGTE(image string, version semver.Version) bool

VersionGTE returns true if the version of the image is greater than or equal to the provided version.

It supports any kind of image reference, but requires the tag to be present.

type Client struct {
	*taloskubernetes.Client
}

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

func NewClientFromKubeletKubeconfig() (*Client, error)

NewClientFromKubeletKubeconfig initializes and returns a Client.

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

NewClientFromPKI initializes and returns a Client.

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

NewForConfig initializes and returns a client using the provided config.

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

Drain evicts all pods on a given node.

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

NodeIPs returns list of node IP addresses by machine type.

Path	Synopsis
inject
kubelet Package kubelet provides minimal client for the kubelet API.	Package kubelet provides minimal client for the kubelet API.