Documentation
¶
Index ¶
- func BuildNodeInfoForNode(node *kube_api.Node, client *kube_client.Client) (*schedulercache.NodeInfo, error)
- func CalculateUtilization(node *kube_api.Node, nodeInfo *schedulercache.NodeInfo) (float64, error)
- func DetailedGetPodsForMove(nodeInfo *schedulercache.NodeInfo, skipNodesWithSystemPods bool, ...) ([]*api.Pod, error)
- func FastGetPodsToMove(nodeInfo *schedulercache.NodeInfo, skipNodesWithSystemPods bool, ...) ([]*api.Pod, error)
- func FindEmptyNodesToRemove(candidates []*kube_api.Node, pods []*kube_api.Pod) []*kube_api.Node
- func GetRequiredPodsForNode(nodename string, client *kube_client.Client) ([]*kube_api.Pod, error)
- func RemoveNodeFromTracker(tracker *UsageTracker, node string, utilization map[string]time.Time)
- type NodeToBeRemoved
- type PredicateChecker
- type UsageRecord
- type UsageTracker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildNodeInfoForNode ¶
func BuildNodeInfoForNode(node *kube_api.Node, client *kube_client.Client) (*schedulercache.NodeInfo, error)
BuildNodeInfoForNode build a NodeInfo structure for the given node as if the node was just created.
func CalculateUtilization ¶
CalculateUtilization calculates utilization of a node, defined as total amount of requested resources divided by capacity.
func DetailedGetPodsForMove ¶
func DetailedGetPodsForMove(nodeInfo *schedulercache.NodeInfo, skipNodesWithSystemPods bool, skipNodesWithLocalStorage bool, client *unversionedclient.Client, minReplicaCount int32) ([]*api.Pod, error)
DetailedGetPodsForMove returns a list of pods that should be moved elsewhere if the node is drained. Raises error if there is an unreplicated pod and force option was not specified. Based on kubectl drain code. It checks whether RC, DS, Jobs and RS that created these pods still exist.
func FastGetPodsToMove ¶
func FastGetPodsToMove(nodeInfo *schedulercache.NodeInfo, skipNodesWithSystemPods bool, skipNodesWithLocalStorage bool) ([]*api.Pod, error)
FastGetPodsToMove returns a list of pods that should be moved elsewhere if the node is drained. Raises error if there is an unreplicated pod and force option was not specified. Based on kubectl drain code. It makes an assumption that RC, DS, Jobs and RS were deleted along with their pods (no abandoned pods with dangling created-by annotation). Usefull for fast checks. Doesn't check i
func FindEmptyNodesToRemove ¶
FindEmptyNodesToRemove finds empty nodes that can be removed.
func GetRequiredPodsForNode ¶
GetRequiredPodsForNode returns a list od pods that would appear on the node if the node was just created (like deamonset and manifest-run pods). It reuses kubectl drain command to get the list.
func RemoveNodeFromTracker ¶
func RemoveNodeFromTracker(tracker *UsageTracker, node string, utilization map[string]time.Time)
RemoveNodeFromTracker removes node from tracker and also cleans the passed utilization map.
Types ¶
type NodeToBeRemoved ¶
type NodeToBeRemoved struct {
// Node to be removed.
Node *kube_api.Node
// PodsToReschedule contains pods on the node that should be rescheduled elsewhere.
PodsToReschedule []*kube_api.Pod
}
NodeToBeRemoved contain information about a node that can be removed.
func FindNodesToRemove ¶
func FindNodesToRemove(candidates []*kube_api.Node, allNodes []*kube_api.Node, pods []*kube_api.Pod, client *kube_client.Client, predicateChecker *PredicateChecker, maxCount int, fastCheck bool, oldHints map[string]string, usageTracker *UsageTracker, timestamp time.Time) (nodesToRemove []NodeToBeRemoved, podReschedulingHints map[string]string, finalError error)
FindNodesToRemove finds nodes that can be removed. Returns also an information about good rescheduling location for each of the pods.
type PredicateChecker ¶
type PredicateChecker struct {
// contains filtered or unexported fields
}
PredicateChecker checks whether all required predicates are matched for given Pod and Node
func NewPredicateChecker ¶
func NewPredicateChecker(kubeClient *kube_client.Client) (*PredicateChecker, error)
NewPredicateChecker builds PredicateChecker.
func NewTestPredicateChecker ¶
func NewTestPredicateChecker() *PredicateChecker
NewTestPredicateChecker builds test version of PredicateChecker.
func (*PredicateChecker) CheckPredicates ¶
func (p *PredicateChecker) CheckPredicates(pod *kube_api.Pod, nodeInfo *schedulercache.NodeInfo) error
CheckPredicates checks if the given pod can be placed on the given node.
func (*PredicateChecker) FitsAny ¶
func (p *PredicateChecker) FitsAny(pod *kube_api.Pod, nodeInfos map[string]*schedulercache.NodeInfo) (string, error)
FitsAny checks if the given pod can be place on any of the given nodes.
type UsageRecord ¶
type UsageRecord struct {
// contains filtered or unexported fields
}
UsageRecord records which node was considered helpful to which node during pod rescheduling analysis.
type UsageTracker ¶
type UsageTracker struct {
// contains filtered or unexported fields
}
UsageTracker track usage relationship between nodes in pod rescheduling calculations.
func NewUsageTracker ¶
func NewUsageTracker() *UsageTracker
NewUsageTracker builds new usage tracker.
func (*UsageTracker) CleanUp ¶
func (tracker *UsageTracker) CleanUp(cutoff time.Time)
CleanUp removes all relations updated before the cutoff time.
func (*UsageTracker) Get ¶
func (tracker *UsageTracker) Get(node string) (data *UsageRecord, found bool)
Get gets the given node UsageRecord, if present
func (*UsageTracker) RegisterUsage ¶
func (tracker *UsageTracker) RegisterUsage(nodeA string, nodeB string, timestamp time.Time)
RegisterUsage registers that node A uses nodeB during usage calculations at time timestamp.
func (*UsageTracker) Unregister ¶
func (tracker *UsageTracker) Unregister(node string)
Unregister removes the given node from all usage records
Source Files