Documentation ¶
Index ¶
- Constants
- func GetEarliestPodStartTime(victims *extenderv1.Victims) *metav1.Time
- func GetNamespacesFromPodAffinityTerm(pod *v1.Pod, podAffinityTerm *v1.PodAffinityTerm) sets.String
- func GetNonzeroRequestForResource(resource v1.ResourceName, requests *v1.ResourceList) int64
- func GetNonzeroRequests(requests *v1.ResourceList) (int64, int64)
- func GetPodAffinityTerms(podAffinity *v1.PodAffinity) (terms []v1.PodAffinityTerm)
- func GetPodAntiAffinityTerms(podAntiAffinity *v1.PodAntiAffinity) (terms []v1.PodAffinityTerm)
- func GetPodFullName(pod *v1.Pod) string
- func GetPodStartTime(pod *v1.Pod) *metav1.Time
- func MoreImportantPod(pod1, pod2 *v1.Pod) bool
- func NodesHaveSameTopologyKey(nodeA, nodeB *v1.Node, topologyKey string) bool
- func PodMatchesTermsNamespaceAndSelector(pod *v1.Pod, namespaces sets.String, selector labels.Selector) bool
- type Clock
- type ErrorChannel
- type RealClock
- type Topologies
Constants ¶
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.
Variables ¶
This section is empty.
Functions ¶
func GetEarliestPodStartTime ¶ added in v1.15.0
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 ¶ added in v1.18.0
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 ¶ added in v1.18.0
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 ¶ added in v1.18.0
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 ¶ added in v1.18.0
func GetPodAffinityTerms(podAffinity *v1.PodAffinity) (terms []v1.PodAffinityTerm)
GetPodAffinityTerms gets pod affinity terms by a pod affinity object.
func GetPodAntiAffinityTerms ¶ added in v1.18.0
func GetPodAntiAffinityTerms(podAntiAffinity *v1.PodAntiAffinity) (terms []v1.PodAffinityTerm)
GetPodAntiAffinityTerms gets pod affinity terms by a pod anti-affinity.
func GetPodFullName ¶
GetPodFullName returns a name that uniquely identifies a pod.
func GetPodStartTime ¶ added in v1.15.0
GetPodStartTime returns start time of the given pod.
func MoreImportantPod ¶ added in v1.15.0
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.
func NodesHaveSameTopologyKey ¶ added in v1.18.0
NodesHaveSameTopologyKey checks if nodeA and nodeB have same label value with given topologyKey as label key. Returns false if topologyKey is empty.
func PodMatchesTermsNamespaceAndSelector ¶ added in v1.18.0
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>.
Types ¶
type ErrorChannel ¶ added in v1.16.0
type ErrorChannel struct {
// contains filtered or unexported fields
}
ErrorChannel supports non-blocking send and receive operation to capture error. A maximum of one error is kept in the channel and the rest of the errors sent are ignored, unless the existing error is received and the channel becomes empty again.
func NewErrorChannel ¶ added in v1.16.0
func NewErrorChannel() *ErrorChannel
NewErrorChannel returns a new ErrorChannel.
func (*ErrorChannel) ReceiveError ¶ added in v1.16.0
func (e *ErrorChannel) ReceiveError() error
ReceiveError receives an error from channel without blocking on the receiver.
func (*ErrorChannel) SendError ¶ added in v1.16.0
func (e *ErrorChannel) SendError(err error)
SendError sends an error without blocking the sender.
func (*ErrorChannel) SendErrorWithCancel ¶ added in v1.16.0
func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc)
SendErrorWithCancel sends an error without blocking the sender and calls cancel function.
type Topologies ¶ added in v1.18.0
type Topologies struct {
DefaultKeys []string
}
Topologies contains topologies information of nodes.
func (*Topologies) NodesHaveSameTopologyKey ¶ added in v1.18.0
func (tps *Topologies) NodesHaveSameTopologyKey(nodeA, nodeB *v1.Node, topologyKey string) bool
NodesHaveSameTopologyKey checks if nodeA and nodeB have same label value with given topologyKey as label key.