util

package
v1.35.0-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 2, 2025 License: Apache-2.0 Imports: 19 Imported by: 186

Documentation

Index

Constants

View Source
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 container 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 node 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 As added in v1.28.0

func As[T any](oldObj, newobj interface{}) (T, T, error)

As converts two objects to the given type. Both objects must be of the same type. If not, an error is returned. nil objects are allowed and will be converted to nil. For oldObj, cache.DeletedFinalStateUnknown is handled and the object stored in it will be converted instead.

func DeletePod added in v1.19.0

func DeletePod(ctx context.Context, cs kubernetes.Interface, pod *v1.Pod) error

DeletePod deletes the given <pod> from API server

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 GetHostPorts added in v1.33.6

func GetHostPorts(pod *v1.Pod) []v1.ContainerPort

GetHostPorts returns the used host ports of pod containers and initContainers with restartPolicy: Always.

func GetPodFullName

func GetPodFullName(pod *v1.Pod) string

GetPodFullName returns a name that uniquely identifies a pod.

func GetPodStartTime added in v1.15.0

func GetPodStartTime(pod *v1.Pod) *metav1.Time

GetPodStartTime returns start time of the given pod or current timestamp if it hasn't started yet.

func IsDRAExtendedResourceName

func IsDRAExtendedResourceName(name v1.ResourceName) bool

IsDRAExtendedResourceName returns true when name is an extended resource name, or an implicit extended resource name derived from device class name with the format of deviceclass.resource.kubernetes.io/<device class name>

func IsScalarResourceName added in v1.20.0

func IsScalarResourceName(name v1.ResourceName) bool

IsScalarResourceName validates the resource for Extended, Hugepages, Native and AttachableVolume resources

func MoreImportantPod added in v1.15.0

func MoreImportantPod(pod1, pod2 *v1.Pod) bool

MoreImportantPod return true when priority of the first pod is higher than the second one. If two pods' priorities are equal, compare their StartTime, treating the older pod as more important.

func PatchPodStatus added in v1.19.13

func PatchPodStatus(ctx context.Context, cs kubernetes.Interface, name string, namespace string, oldStatus *v1.PodStatus, newStatus *v1.PodStatus) error

PatchPodStatus calculates the delta bytes change from <old.Status> to <newStatus>, and then submit a request to API server to patch the pod changes.

func Retriable added in v1.26.0

func Retriable(err error) bool

Retriable defines the retriable errors during a scheduling cycle.

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL