tools

Documentation

Index

• func CreateAndStartRecorder(kubeclientset kubernetes.Interface, name string) record.EventRecorder
• func GetNodeAPIVersion(node *corev1.Node, pods []*corev1.Pod) string
• func GetNodeKubeControllerManagerVersion(node *corev1.Node, pods []*corev1.Pod) string
• func GetNodeSchedulerVersion(node *corev1.Node, pods []*corev1.Pod) string
• func IndexByIDKeyFun() cache.Indexers
• func MetaResourceNamespaceKeyFunc(kind string, obj interface{}) (string, error)
• func NodeIsReady(node *corev1.Node) bool
• func NodeIsTargetKubernetesVersion(cup *provisioncsv3.ClusterUpgrade, node *corev1.Node, pods []*corev1.Pod) bool
• func SplitMetaResourceNamespaceKeyFunc(key string) (kind, namespace, name string, err error)

Functions

func CreateAndStartRecorder

func CreateAndStartRecorder(kubeclientset kubernetes.Interface, name string) record.EventRecorder

CreateAndStartRecorder creates and starts a new recorder with the given name

func GetNodeAPIVersion

func GetNodeAPIVersion(node *corev1.Node, pods []*corev1.Pod) string

GetNodeAPIVersion returns the version of the static pod running the api server

func GetNodeKubeControllerManagerVersion

func GetNodeKubeControllerManagerVersion(node *corev1.Node, pods []*corev1.Pod) string

GetNodeKubeControllerManagerVersion returns the version of the static pod running the kube controller manager

func GetNodeSchedulerVersion

func GetNodeSchedulerVersion(node *corev1.Node, pods []*corev1.Pod) string

GetNodeSchedulerVersion returns the version of the static pod running the scheduler

func IndexByIDKeyFun

func IndexByIDKeyFun() cache.Indexers

IndexByIDKeyFun returns a function for indexing a cache by ID

func MetaResourceNamespaceKeyFunc

func MetaResourceNamespaceKeyFunc(kind string, obj interface{}) (string, error)

MetaResourceNamespaceKeyFunc is a convenient KeyFunc which knows how to make keys for API objects which implement meta.Interface. The key uses the format <kind>/<namespace>/<name> unless <namespace> is empty, then it's <kind>/<name>.

func NodeIsReady

func NodeIsReady(node *corev1.Node) bool

NodeIsReady returns true if the given node has a Ready status, else false. See https://kubernetes.io/docs/concepts/nodes/node/#condition for more info.

func NodeIsTargetKubernetesVersion

func NodeIsTargetKubernetesVersion(cup *provisioncsv3.ClusterUpgrade, node *corev1.Node, pods []*corev1.Pod) bool

NodeIsTargetKubernetesVersion checks if the current node version matches the target version of the cluster upgrade that is being processed. This only checks that the kubelet is up to date on worker nodes, and that on masters kubelet and static pods are at the desired version. NOTE: this should only be called with upgrades of type Kubernetes

func SplitMetaResourceNamespaceKeyFunc

func SplitMetaResourceNamespaceKeyFunc(key string) (kind, namespace, name string, err error)

SplitMetaResourceNamespaceKeyFunc returns the kind, namespace and name that MetaResourceNamespaceKeyFunc encoded into key.