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
• type TestGroup
• func (g TestGroup) Codec() runtime.Codec
• func (g TestGroup) ResourcePath(resource, namespace, name string) string
• func (g TestGroup) ResourcePathWithPrefix(prefix, resource, namespace, name string) string
• func (g TestGroup) SelfLink(resource, name string) string
• func (g TestGroup) SubResourcePath(resource, namespace, name, sub string) string

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

type TestGroup ¶

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

var (
	Groups = make(map[string]TestGroup)
	Test   TestGroup
)

func (TestGroup) Codec ¶

func (g TestGroup) Codec() runtime.Codec

Codec returns the codec for the API version to test against, as set by the KUBE_TEST_API_TYPE env var.

func (TestGroup) ResourcePath ¶

func (g TestGroup) ResourcePath(resource, namespace, name string) string

ResourcePath returns the appropriate path for the given resource, namespace and name. For example, this is of the form: /api/v1/namespaces/foo/pods/pod0 for v1.

func (TestGroup) ResourcePathWithPrefix ¶

func (g TestGroup) ResourcePathWithPrefix(prefix, resource, namespace, name string) string

ResourcePathWithPrefix returns the appropriate path for the given prefix (watch, proxy, redirect, etc), resource, namespace and name. For ex, this is of the form: /api/v1/watch/namespaces/foo/pods/pod0 for v1.

func (TestGroup) SelfLink ¶

func (g TestGroup) SelfLink(resource, name string) string

SelfLink returns a self link that will appear to be for the version Version(). 'resource' should be the resource path, e.g. "pods" for the Pod type. 'name' should be empty for lists.

func (TestGroup) SubResourcePath ¶

func (g TestGroup) SubResourcePath(resource, namespace, name, sub string) string

SubResourcePath returns the appropriate path for the given resource, namespace, name and subresource.

Source Files ¶

backoff_utils.go testutil.go utils.go