k8sutil

Jun 13, 2018

Changes in this version

+ func GetNodeRetry(nc v1core.NodeInterface, node string) (*v1api.Node, error)

+ func RetryOnError(backoff wait.Backoff, fn func() error) error

Jan 25, 2018

Changes in this version

+ func SetNodeAnnotationsLabels(nc v1core.NodeInterface, node string, a, l map[string]string) error

Aug 8, 2017

Changes in this version

+ func DeleteNodeAnnotations(nc v1core.NodeInterface, node string, ks []string) error

+ func DeleteNodeLabels(nc v1core.NodeInterface, node string, ks []string) error

+ func FilterContainerLinuxNodes(nodes []v1api.Node) []v1api.Node

+ func FilterNodesByRequirement(nodes []v1api.Node, req *labels.Requirement) []v1api.Node

+ func GetClient(path string) (*kubernetes.Clientset, error)

+ func NewRequirementOrDie(key string, op selection.Operator, vals []string) *labels.Requirement

Apr 27, 2017

Changes in this version

+ var DefaultBackoff = wait.Backoff

+ var DefaultRetry = wait.Backoff

+ func FilterNodesByAnnotation(list []v1api.Node, sel fields.Selector) []v1api.Node

+ func FilterPods(pods []v1api.Pod, filter func(*v1api.Pod) bool) (newpods []v1api.Pod)

+ func InClusterClient() (*kubernetes.Clientset, error)

+ func NodeAnnotationCondition(selector fields.Selector) watch.ConditionFunc

+ func RetryOnConflict(backoff wait.Backoff, fn func() error) error

+ func SetNodeAnnotations(nc v1core.NodeInterface, node string, m map[string]string) error

+ func SetNodeLabels(nc v1core.NodeInterface, node string, m map[string]string) error

+ func Unschedulable(nc v1core.NodeInterface, node string, sched bool) error

+ func UpdateNodeRetry(nc v1core.NodeInterface, node string, f func(*v1api.Node)) error

+ type VersionInfo struct

+ Group string

+ ID string

+ Name string

+ Version string

+ func GetVersionInfo() (*VersionInfo, error)