import "k8s.io/kubernetes/pkg/scheduler/util"
clock.go non_zero.go topologies.go utils.go
const ( // DefaultMilliCPURequest defines default milli cpu request number. DefaultMilliCPURequest int64 = 100 // 0.1 core // DefaultMemoryRequest defines default memory request size. DefaultMemoryRequest int64 = 200 * 1024 * 1024 // 200 MB )
For each of these resources, a pod that doesn't request the resource explicitly will be treated as having requested the amount indicated below, for the purpose of computing priority only. This ensures that when scheduling zero-request pods, such pods will not all be scheduled to the machine with the smallest in-use request, and that when scheduling regular pods, such pods will not see zero-request pods as consuming no resources whatsoever. We chose these values to be similar to the resources that we give to cluster addon pods (#10653). But they are pretty arbitrary. As described in #11713, we use request instead of limit to deal with resource requirements.
func ClearNominatedNodeName(cs kubernetes.Interface, pods ...*v1.Pod) utilerrors.Aggregate
ClearNominatedNodeName internally submit a patch request to API server to set each pods[*].Status.NominatedNodeName> to "".
DeletePod deletes the given <pod> from API server
func GetEarliestPodStartTime(victims *extenderv1.Victims) *metav1.Time
GetEarliestPodStartTime returns the earliest start time of all pods that have the highest priority among all victims.
func GetNamespacesFromPodAffinityTerm(pod *v1.Pod, podAffinityTerm *v1.PodAffinityTerm) sets.String
GetNamespacesFromPodAffinityTerm returns a set of names according to the namespaces indicated in podAffinityTerm. If namespaces is empty it considers the given pod's namespace.
func GetNonzeroRequestForResource(resource v1.ResourceName, requests *v1.ResourceList) int64
GetNonzeroRequestForResource returns the default resource request if none is found or what is provided on the request.
func GetNonzeroRequests(requests *v1.ResourceList) (int64, int64)
GetNonzeroRequests returns the default cpu and memory resource request if none is found or what is provided on the request.
func GetPodAffinityTerms(affinity *v1.Affinity) (terms []v1.PodAffinityTerm)
GetPodAffinityTerms gets pod affinity terms by a pod affinity object.
func GetPodAntiAffinityTerms(affinity *v1.Affinity) (terms []v1.PodAffinityTerm)
GetPodAntiAffinityTerms gets pod affinity terms by a pod anti-affinity.
GetPodFullName returns a name that uniquely identifies a pod.
GetPodStartTime returns start time of the given pod or current timestamp if it hasn't started yet.
func IsScalarResourceName(name v1.ResourceName) bool
IsScalarResourceName validates the resource for Extended, Hugepages, Native and AttachableVolume resources
MoreImportantPod return true when priority of the first pod is higher than the second one. If two pods' priorities are equal, compare their StartTime. It takes arguments of the type "interface{}" to be used with SortableList, but expects those arguments to be *v1.Pod.
NodesHaveSameTopologyKey checks if nodeA and nodeB have same label value with given topologyKey as label key. Returns false if topologyKey is empty.
PatchPod calculates the delta bytes change from <old> to <new>, and then submit a request to API server to patch the pod changes.
func PodMatchesTermsNamespaceAndSelector(pod *v1.Pod, namespaces sets.String, selector labels.Selector) bool
PodMatchesTermsNamespaceAndSelector returns true if the given <pod> matches the namespace and selector defined by <affinityPod>`s <term>.
Clock provides an interface for getting the current time
type RealClock struct{}
RealClock implements a clock using time
Now returns the current time with time.Now
Topologies contains topologies information of nodes.
NodesHaveSameTopologyKey checks if nodeA and nodeB have same label value with given topologyKey as label key.
Package util imports 18 packages (graph) and is imported by 243 packages. Updated 2020-11-13. Refresh now. Tools for package owners.