utils

Documentation

Index

• Constants
• func GetNamespacesFromPodAffinityTerm(pod *v1.Pod, podAffinityTerm *v1.PodAffinityTerm) sets.String
• func GetPodQOS(pod *v1.Pod) v1.PodQOSClass
• func GetPodSource(pod *v1.Pod) (string, error)
• func GetPriorityFromPriorityClass(ctx context.Context, client clientset.Interface, name string) (int32, error)
• func GetPriorityFromStrategyParams(ctx context.Context, client clientset.Interface, ...) (priority int32, err error)
• func GetResourceRequest(pod *v1.Pod, resource v1.ResourceName) int64
• func GetResourceRequestQuantity(pod *v1.Pod, resourceName v1.ResourceName) resource.Quantity
• func IsCriticalPod(pod *v1.Pod) bool
• func IsMirrorPod(pod *v1.Pod) bool
• func IsStaticPod(pod *v1.Pod) bool
• func NodeSelectorRequirementsAsSelector(nsm []v1.NodeSelectorRequirement) (labels.Selector, error)
• func PodMatchNodeSelector(pod *v1.Pod, node *v1.Node) (bool, error)
• func PodMatchesTermsNamespaceAndSelector(pod *v1.Pod, namespaces sets.String, selector labels.Selector) bool
• func PodRequestsAndLimits(pod *v1.Pod) (reqs, limits v1.ResourceList)
• func PodToleratesTaints(pod *v1.Pod, taintsOfNodes map[string][]v1.Taint) bool
• func TolerationsTolerateTaint(tolerations []v1.Toleration, taint *v1.Taint) bool
• func TolerationsTolerateTaintsWithFilter(tolerations []v1.Toleration, taints []v1.Taint, applyFilter taintsFilterFunc) bool
• type QOSList

Constants

const (
	// owner: @jinxu
	// beta: v1.10
	//
	// New local storage types to support local storage capacity isolation
	LocalStorageCapacityIsolation featuregate.Feature = "LocalStorageCapacityIsolation"

	// owner: @egernst
	// alpha: v1.16
	//
	// Enables PodOverhead, for accounting pod overheads which are specific to a given RuntimeClass
	PodOverhead featuregate.Feature = "PodOverhead"
)

const SystemCriticalPriority = 2 * int32(1000000000)

Functions

func GetNamespacesFromPodAffinityTerm

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 GetPodQOS

func GetPodQOS(pod *v1.Pod) v1.PodQOSClass

GetPodQOS returns the QoS class of a pod. A pod is besteffort if none of its containers have specified any requests or limits. A pod is guaranteed only when requests and limits are specified for all the containers and they are equal. A pod is burstable if limits and requests do not match across all containers.

func GetPodSource

func GetPodSource(pod *v1.Pod) (string, error)

GetPodSource returns the source of the pod based on the annotation.

func GetPriorityFromPriorityClass

func GetPriorityFromPriorityClass(ctx context.Context, client clientset.Interface, name string) (int32, error)

GetPriorityFromPriorityClass gets priority from the given priority class. If no priority class is provided, it will return SystemCriticalPriority by default.

func GetPriorityFromStrategyParams

func GetPriorityFromStrategyParams(ctx context.Context, client clientset.Interface, params *api.StrategyParameters) (priority int32, err error)

GetPriorityFromStrategyParams gets priority from the given StrategyParameters. It will return SystemCriticalPriority by default.

func GetResourceRequest

func GetResourceRequest(pod *v1.Pod, resource v1.ResourceName) int64

GetResourceRequest finds and returns the request value for a specific resource.

func GetResourceRequestQuantity

func GetResourceRequestQuantity(pod *v1.Pod, resourceName v1.ResourceName) resource.Quantity

GetResourceRequestQuantity finds and returns the request quantity for a specific resource.

func IsCriticalPod

func IsCriticalPod(pod *v1.Pod) bool

IsCriticalPod returns true if the pod is a static or mirror pod.

func IsMirrorPod

func IsMirrorPod(pod *v1.Pod) bool

IsMirrorPod returns true if the passed Pod is a Mirror Pod.

func IsStaticPod

func IsStaticPod(pod *v1.Pod) bool

IsStaticPod returns true if the pod is a static pod.

func NodeSelectorRequirementsAsSelector

func NodeSelectorRequirementsAsSelector(nsm []v1.NodeSelectorRequirement) (labels.Selector, error)

NodeSelectorRequirementsAsSelector converts the []NodeSelectorRequirement api type into a struct that implements labels.Selector.

func PodMatchNodeSelector

func PodMatchNodeSelector(pod *v1.Pod, node *v1.Node) (bool, error)

PodMatchNodeSelector checks if a pod node selector matches the node label.

func PodMatchesTermsNamespaceAndSelector

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>.

func PodRequestsAndLimits

func PodRequestsAndLimits(pod *v1.Pod) (reqs, limits v1.ResourceList)

PodRequestsAndLimits returns a dictionary of all defined resources summed up for all containers of the pod. If PodOverhead feature is enabled, pod overhead is added to the total container resource requests and to the total container limits which have a non-zero quantity.

func PodToleratesTaints

func PodToleratesTaints(pod *v1.Pod, taintsOfNodes map[string][]v1.Taint) bool

PodToleratesTaints returns true if a pod tolerates one node's taints

func TolerationsTolerateTaint

func TolerationsTolerateTaint(tolerations []v1.Toleration, taint *v1.Taint) bool

TolerationsTolerateTaint checks if taint is tolerated by any of the tolerations.

func TolerationsTolerateTaintsWithFilter

func TolerationsTolerateTaintsWithFilter(tolerations []v1.Toleration, taints []v1.Taint, applyFilter taintsFilterFunc) bool

TolerationsTolerateTaintsWithFilter checks if given tolerations tolerates all the taints that apply to the filter in given taint list.

Types

type QOSList

type QOSList map[v1.ResourceName]v1.PodQOSClass

QOSList is a set of (resource name, QoS class) pairs.