package util

import "k8s.io/kubernetes/pkg/scheduler/util"

Index ¶

• func GetContainerPorts(pods ...*v1.Pod) []*v1.ContainerPort
• func GetEarliestPodStartTime(victims *extenderv1.Victims) *metav1.Time
• func GetPodFullName(pod *v1.Pod) string
• func GetPodStartTime(pod *v1.Pod) *metav1.Time
• func MoreImportantPod(pod1, pod2 *v1.Pod) bool
• type Clock
• type ErrorChannel
• func NewErrorChannel() *ErrorChannel
• func (e *ErrorChannel) ReceiveError() error
• func (e *ErrorChannel) SendError(err error)
• func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc)
• type RealClock
• func (RealClock) Now() time.Time

Functions ¶

func GetContainerPorts ¶

func GetContainerPorts(pods ...*v1.Pod) []*v1.ContainerPort

GetContainerPorts returns the used host ports of Pods: if 'port' was used, a 'port:true' pair will be in the result; but it does not resolve port conflict.

func GetEarliestPodStartTime ¶

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 GetPodFullName ¶

func GetPodFullName(pod *v1.Pod) string

GetPodFullName returns a name that uniquely identifies a pod.

func GetPodStartTime ¶

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 MoreImportantPod ¶

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. It takes arguments of the type "interface{}" to be used with SortableList, but expects those arguments to be *v1.Pod.

Types ¶

type Clock ¶

type Clock interface {
	Now() time.Time
}

Clock provides an interface for getting the current time

type ErrorChannel ¶

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 ¶

func NewErrorChannel() *ErrorChannel

NewErrorChannel returns a new ErrorChannel.

func (*ErrorChannel) ReceiveError ¶

func (e *ErrorChannel) ReceiveError() error

ReceiveError receives an error from channel without blocking on the receiver.

func (*ErrorChannel) SendError ¶

func (e *ErrorChannel) SendError(err error)

SendError sends an error without blocking the sender.

func (*ErrorChannel) SendErrorWithCancel ¶

func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc)

SendErrorWithCancel sends an error without blocking the sender and calls cancel function.

type RealClock ¶

type RealClock struct{}

RealClock implements a clock using time

func (RealClock) Now ¶

func (RealClock) Now() time.Time

Now returns the current time with time.Now

Source Files ¶

clock.go error_channel.go utils.go