Versions in this module Expand all Collapse all v0 v0.1.1 Dec 29, 2020 Changes in this version + const BatchPodLabel + const BetaHostNameKey + const ClusterID + const CreatedbyDescheduler + const DescheduleCount + const GlobalLabel + const HostNameKey + const LabelOSBeta + const NodeType + const SelectedNodeKey + const SelectorKey + const TaintNodeNotReady + const TaintNodeUnreachable + const TrippedLabels + const VirtualKubeletLabel + const VirtualPodLabel + func CreateJSONPatch(original, new interface{}) ([]byte, error) + func CreateMergePatch(original, new interface{}) ([]byte, error) + func GetClusterID(node *corev1.Node) string + func GetRequestFromContainer(container *corev1.Container) *common.Resource + func GetRequestFromPod(pod *corev1.Pod) *common.Resource + func GetUpdatedPod(orig, update *corev1.Pod, ignoreLabels []string) + func IsVirtualNode(node *corev1.Node) bool + func IsVirtualPod(pod *corev1.Pod) bool + func NewClient(configPath string, opts ...Opts) (kubernetes.Interface, error) + func NewMetricClient(configPath string, opts ...Opts) (versioned.Interface, error) + func RecoverLabels(labels map[string]string, annotations map[string]string) + func ReplacePodNodeNameNodeAffinity(affinity *v1.Affinity, ownerID string, expireTime time.Duration, ...) (*v1.Affinity, int) + func SetupSignalHandler() <-chan struct + func TrimObjectMeta(meta *metav1.ObjectMeta) + func TrimPod(pod *corev1.Pod, ignoreLabels []string) *corev1.Pod + func UpdateConfigMap(old, new *corev1.ConfigMap) + func UpdateSecret(old, new *corev1.Secret) + type CheckValidFunc func(string, string, time.Duration) bool + type ClustersNodeSelection struct + Affinity *corev1.Affinity + NodeSelector map[string]string + Tolerations []corev1.Toleration + func ConvertAnnotations(annotation map[string]string) *ClustersNodeSelection + type Opts func(*rest.Config) + type UnschedulableCache struct + func NewUnschedulableCache() *UnschedulableCache + func (c *UnschedulableCache) Add(node, ownerID string) + func (c *UnschedulableCache) GetFreezeNodes(ownerID string) []string + func (c *UnschedulableCache) GetFreezeTime(node, ownerID string) *time.Time
Go to main page