queue

package

Go to main page

Versions in this module

v1

v1.33.0-alpha.0

Nov 25, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0

Dec 11, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

Changes in this version

+ const DefaultPodInitialBackoffDuration

+ const DefaultPodMaxBackoffDuration

+ const DefaultPodMaxInUnschedulablePodsDuration

+ type Option func(*priorityQueueOptions)

+ func WithClock(clock clock.Clock) Option

+ func WithMetricsRecorder(recorder metrics.MetricAsyncRecorder) Option

+ func WithPluginMetricsSamplePercent(percent int) Option

+ func WithPodInitialBackoffDuration(duration time.Duration) Option

+ func WithPodLister(pl listersv1.PodLister) Option

+ func WithPodMaxBackoffDuration(duration time.Duration) Option

+ func WithPodMaxInUnschedulablePodsDuration(duration time.Duration) Option

+ func WithPreEnqueuePluginMap(m map[string][]framework.PreEnqueuePlugin) Option

+ func WithQueueingHintMapPerProfile(m QueueingHintMapPerProfile) Option

+ type PreEnqueueCheck func(pod *v1.Pod) bool

+ type PriorityQueue struct

+ func NewPriorityQueue(lessFn framework.LessFunc, informerFactory informers.SharedInformerFactory, ...) *PriorityQueue

+ func NewTestQueue(ctx context.Context, lessFn framework.LessFunc, opts ...Option) *PriorityQueue

+ func NewTestQueueWithInformerFactory(ctx context.Context, lessFn framework.LessFunc, ...) *PriorityQueue

+ func NewTestQueueWithObjects(ctx context.Context, lessFn framework.LessFunc, objs []runtime.Object, ...) *PriorityQueue

+ func (npm PriorityQueue) AddNominatedPod(logger klog.Logger, pi *framework.PodInfo, ...)

+ func (npm PriorityQueue) DeleteNominatedPodIfExists(pod *v1.Pod)

+ func (npm PriorityQueue) UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo)

+ func (p *PriorityQueue) Activate(logger klog.Logger, pods map[string]*v1.Pod)

+ func (p *PriorityQueue) Add(logger klog.Logger, pod *v1.Pod)

+ func (p *PriorityQueue) AddUnschedulableIfNotPresent(logger klog.Logger, pInfo *framework.QueuedPodInfo, podSchedulingCycle int64) error

+ func (p *PriorityQueue) AssignedPodAdded(logger klog.Logger, pod *v1.Pod)

+ func (p *PriorityQueue) AssignedPodUpdated(logger klog.Logger, oldPod, newPod *v1.Pod, event framework.ClusterEvent)

+ func (p *PriorityQueue) Close()

+ func (p *PriorityQueue) Delete(pod *v1.Pod)

+ func (p *PriorityQueue) Done(pod types.UID)

+ func (p *PriorityQueue) GetPod(name, namespace string) (pInfo *framework.QueuedPodInfo, ok bool)

+ func (p *PriorityQueue) InFlightPods() []*v1.Pod

+ func (p *PriorityQueue) MoveAllToActiveOrBackoffQueue(logger klog.Logger, event framework.ClusterEvent, oldObj, newObj interface{}, ...)

+ func (p *PriorityQueue) NominatedPodsForNode(nodeName string) []*framework.PodInfo

+ func (p *PriorityQueue) PendingPods() ([]*v1.Pod, string)

+ func (p *PriorityQueue) PodsInActiveQ() []*v1.Pod

+ func (p *PriorityQueue) Pop(logger klog.Logger) (*framework.QueuedPodInfo, error)

+ func (p *PriorityQueue) Run(logger klog.Logger)

+ func (p *PriorityQueue) SchedulingCycle() int64

+ func (p *PriorityQueue) Update(logger klog.Logger, oldPod, newPod *v1.Pod)

+ type QueueingHintFunction struct

+ PluginName string

+ QueueingHintFn framework.QueueingHintFn

+ type QueueingHintMap map[framework.ClusterEvent][]*QueueingHintFunction

+ type QueueingHintMapPerProfile map[string]QueueingHintMap

+ type SchedulingQueue interface

+ Activate func(logger klog.Logger, pods map[string]*v1.Pod)

+ Add func(logger klog.Logger, pod *v1.Pod)

+ AddUnschedulableIfNotPresent func(logger klog.Logger, pod *framework.QueuedPodInfo, podSchedulingCycle int64) error

+ AssignedPodAdded func(logger klog.Logger, pod *v1.Pod)

+ AssignedPodUpdated func(logger klog.Logger, oldPod, newPod *v1.Pod, event framework.ClusterEvent)

+ Close func()

+ Delete func(pod *v1.Pod)

+ Done func(types.UID)

+ GetPod func(name, namespace string) (*framework.QueuedPodInfo, bool)

+ InFlightPods func() []*v1.Pod

+ MoveAllToActiveOrBackoffQueue func(logger klog.Logger, event framework.ClusterEvent, oldObj, newObj interface{}, ...)

+ PendingPods func() ([]*v1.Pod, string)

+ PodsInActiveQ func() []*v1.Pod

+ Pop func(logger klog.Logger) (*framework.QueuedPodInfo, error)

+ Run func(logger klog.Logger)

+ SchedulingCycle func() int64

+ Update func(logger klog.Logger, oldPod, newPod *v1.Pod)

+ func NewSchedulingQueue(lessFn framework.LessFunc, informerFactory informers.SharedInformerFactory, ...) SchedulingQueue

+ type UnschedulablePods struct

v1.32.0-rc.2

Dec 5, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0-rc.1

Dec 3, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0-rc.0

Nov 26, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0-beta.0

Nov 5, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0-alpha.3

Oct 29, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0-alpha.2

Oct 17, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

v1.32.0-alpha.1

Oct 1, 2024 GO-2022-0617

GO-2022-0617: WITHDRAWN: Potential proxy IP restriction bypass in Kubernetes in k8s.io/kubernetes

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