package util

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

Index ¶

• func GetUsedPorts(pods ...*v1.Pod) map[int]bool
• type PodBackoff
• func CreateDefaultPodBackoff() *PodBackoff
• func CreatePodBackoff(defaultDuration, maxDuration time.Duration) *PodBackoff
• func CreatePodBackoffWithClock(defaultDuration, maxDuration time.Duration, clock clock) *PodBackoff
• func (p *PodBackoff) Gc()
• func (p *PodBackoff) GetEntry(podID ktypes.NamespacedName) *backoffEntry
• func (p *PodBackoff) MaxDuration() time.Duration

Functions ¶

func GetUsedPorts ¶

func GetUsedPorts(pods ...*v1.Pod) map[int]bool

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

Types ¶

type PodBackoff ¶

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

func CreateDefaultPodBackoff ¶

func CreateDefaultPodBackoff() *PodBackoff

func CreatePodBackoff ¶

func CreatePodBackoff(defaultDuration, maxDuration time.Duration) *PodBackoff

func CreatePodBackoffWithClock ¶

func CreatePodBackoffWithClock(defaultDuration, maxDuration time.Duration, clock clock) *PodBackoff

func (*PodBackoff) Gc ¶

func (p *PodBackoff) Gc()

func (*PodBackoff) GetEntry ¶

func (p *PodBackoff) GetEntry(podID ktypes.NamespacedName) *backoffEntry

func (*PodBackoff) MaxDuration ¶

func (p *PodBackoff) MaxDuration() time.Duration

Source Files ¶

backoff_utils.go utils.go