queue

type Compare = func(pod0, pod1 *v1.Pod) bool

type ErrNoMatchingPod struct {
	// contains filtered or unexported fields
}

type FIFOQueue struct {
	// contains filtered or unexported fields
}

type Metrics struct {
	PendingPodsNum int
}

type PodQueue interface {
	// Push pushes the pod to the "end" of this PodQueue.
	Push(pod *v1.Pod) error

	// Pop pops the pod on the "front" of this PodQueue.
	// This method never blocks; Immediately returns ErrEmptyQueue if the queue is empty.
	Pop() (*v1.Pod, error)

	// Front refers (not pops) the pod on the "front" of this PodQueue.
	// This method never bocks; Immediately returns ErrEmptyQueue if the queue is empty.
	Front() (*v1.Pod, error)

	// Delete deletes the pod from this PodQueue.
	// Returns true if the pod is found, or false otherwise.
	Delete(podNamespace, podName string) bool

	// Update updates the pod to the newPod.
	// Returns ErrNoMatchingPod if an original pod is not found.
	// The original and new pods must have the same namespace/name; Otherwise ErrDifferentNames is
	// returned in the second field.
	Update(podNamespace, podName string, newPod *v1.Pod) error

	// NominatedPods returns a list of pods for which the node is nominated for scheduling.
	NominatedPods(nodeName string) []*v1.Pod

	// UpdateNominatedNode updates the node nomination for the pod.
	UpdateNominatedNode(pod *v1.Pod, nodeName string) error

	// RemoveNominatedNode removes the node nomination for the pod.
	RemoveNominatedNode(pod *v1.Pod) error

	// Metrics returns a metrics of this PodQueue.
	Metrics() Metrics
}

type PriorityQueue struct {
	// contains filtered or unexported fields
}