util

Sep 28, 2017

Changes in this version

+ var ErrCloudInstance = errors.New("cloud provider doesn't support instances")

+ func CreateAddNodeHandler(f func(node *v1.Node) error) func(obj interface{})

+ func CreateDeleteNodeHandler(f func(node *v1.Node) error) func(obj interface{})

+ func CreateUpdateNodeHandler(f func(oldNode, newNode *v1.Node) error) func(oldObj, newObj interface{})

+ func DeletePods(kubeClient clientset.Interface, recorder record.EventRecorder, ...) (bool, error)

+ func ForcefullyDeleteNode(kubeClient clientset.Interface, nodeName string) error

+ func ForcefullyDeletePod(c clientset.Interface, pod *v1.Pod) error

+ func MarkAllPodsNotReady(kubeClient clientset.Interface, node *v1.Node) error

+ func NodeExistsInCloudProvider(cloud cloudprovider.Interface, nodeName types.NodeName) (bool, error)

+ func NodeRunningOutdatedKubelet(node *v1.Node) bool

+ func RecordNodeEvent(recorder record.EventRecorder, ...)

+ func RecordNodeStatusChange(recorder record.EventRecorder, node *v1.Node, newStatus string)

+ func SetPodTerminationReason(kubeClient clientset.Interface, pod *v1.Pod, nodeName string) (*v1.Pod, error)

+ func SwapNodeControllerTaint(kubeClient clientset.Interface, taintsToAdd, taintsToRemove []*v1.Taint, ...) bool