util

Documentation

Index

• Constants
• func FilterPodsByNameSpaces(names sets.String, pods []*api.Pod) []*api.Pod
• func GetNamespacesFromPodAffinityTerm(pod *api.Pod, podAffinityTerm api.PodAffinityTerm) sets.String
• func GetNonzeroRequests(requests *api.ResourceList) (int64, int64)
• func NodesHaveSameTopologyKeyInternal(nodeA, nodeB *api.Node, topologyKey string) bool
• type Topologies
  • func (tps *Topologies) CheckIfPodMatchPodAffinityTerm(podA *api.Pod, podB *api.Pod, podBAffinityTerm api.PodAffinityTerm, ...) (bool, error)
  • func (tps *Topologies) NodesHaveSameTopologyKey(nodeA *api.Node, nodeB *api.Node, topologyKey string) bool

Constants

const DefaultMemoryRequest int64 = 200 * 1024 * 1024 // 200 MB

const DefaultMilliCpuRequest int64 = 100 // 0.1 core

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.

Functions

func FilterPodsByNameSpaces

func FilterPodsByNameSpaces(names sets.String, pods []*api.Pod) []*api.Pod

FilterPodsByNameSpaces filters the pods based the given list of namespaces, empty set of namespaces means all namespaces.

func GetNamespacesFromPodAffinityTerm

func GetNamespacesFromPodAffinityTerm(pod *api.Pod, podAffinityTerm api.PodAffinityTerm) sets.String

GetNamespacesFromPodAffinityTerm returns a set of names according to the namespaces indicated in podAffinityTerm. if the NameSpaces is nil considers the given pod's namespace if the Namespaces is empty list then considers all the namespaces

func GetNonzeroRequests

func GetNonzeroRequests(requests *api.ResourceList) (int64, int64)

GetNonzeroRequests returns the default resource request if none is found or what is provided on the request TODO: Consider setting default as a fixed fraction of machine capacity (take "capacity api.ResourceList" as an additional argument here) rather than using constants

func NodesHaveSameTopologyKeyInternal

func NodesHaveSameTopologyKeyInternal(nodeA, nodeB *api.Node, topologyKey string) bool

NodesHaveSameTopologyKeyInternal checks if nodeA and nodeB have same label value with given topologyKey as label key.

Types

type Topologies

type Topologies struct {
	DefaultKeys []string
}

func (*Topologies) CheckIfPodMatchPodAffinityTerm

func (tps *Topologies) CheckIfPodMatchPodAffinityTerm(podA *api.Pod, podB *api.Pod, podBAffinityTerm api.PodAffinityTerm, getNodeA, getNodeB getNodeFunc) (bool, error)

CheckIfPodMatchPodAffinityTerm checks if podB's affinity request is compatible with podA

func (*Topologies) NodesHaveSameTopologyKey

func (tps *Topologies) NodesHaveSameTopologyKey(nodeA *api.Node, nodeB *api.Node, topologyKey string) bool

NodesHaveSameTopologyKey checks if nodeA and nodeB have same label value with given topologyKey as label key. If the topologyKey is nil/empty, check if the two nodes have any of the default topologyKeys, and have same corresponding label value.