package autoscaling

import "k8s.io/kubernetes/test/e2e/autoscaling"

Index ¶

• Constants
• func ReserveMemory(f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration) func() error
• func ReserveMemoryWithPriority(f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration, priorityClassName string) func() error
• func ReserveMemoryWithSelectorAndTolerations(f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration, selector map[string]string, tolerations []v1.Toleration) func() error
• func SIGDescribe(text string, body func()) bool
• func ScheduleAnySingleGpuPod(f *framework.Framework, id string) error
• func ScheduleGpuPod(f *framework.Framework, id string, gpuType string, gpuLimit int64) error
• func WaitForClusterSizeFunc(c clientset.Interface, sizeFunc func(int) bool, timeout time.Duration) error
• func WaitForClusterSizeFuncWithUnready(c clientset.Interface, sizeFunc func(int) bool, timeout time.Duration, expectedUnready int) error
• type CriticalAddonsOnlyError
• func (CriticalAddonsOnlyError) Error() string
• type CustomMetricTestCase
• func (tc *CustomMetricTestCase) Run()
• type DNSParamsLinear
• type HPAScaleTest

Package Files ¶

autoscaling_timer.go cluster_autoscaler_scalability.go cluster_size_autoscaling.go custom_metrics_stackdriver_autoscaling.go dns_autoscaling.go framework.go horizontal_pod_autoscaling.go

Constants ¶

const (
    DNSdefaultTimeout      = 5 * time.Minute
    ClusterAddonLabelKey   = "k8s-app"
    DNSLabelName           = "kube-dns"
    DNSAutoscalerLabelName = "kube-dns-autoscaler"
)

Constants used in dns-autoscaling test.

func ReserveMemory ¶ Uses

func ReserveMemory(f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration) func() error

ReserveMemory creates a replication controller with pods that, in summation, request the specified amount of memory.

func ReserveMemoryWithPriority ¶ Uses

func ReserveMemoryWithPriority(f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration, priorityClassName string) func() error

ReserveMemoryWithPriority creates a replication controller with pods with priority that, in summation, request the specified amount of memory.

func ReserveMemoryWithSelectorAndTolerations ¶ Uses

func ReserveMemoryWithSelectorAndTolerations(f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration, selector map[string]string, tolerations []v1.Toleration) func() error

ReserveMemoryWithSelectorAndTolerations creates a replication controller with pods with node selector that, in summation, request the specified amount of memory.

func SIGDescribe ¶ Uses

func SIGDescribe(text string, body func()) bool

SIGDescribe annotates the test with the SIG label.

func ScheduleAnySingleGpuPod ¶ Uses

func ScheduleAnySingleGpuPod(f *framework.Framework, id string) error

ScheduleAnySingleGpuPod schedules a pod which requires single GPU of any type

func ScheduleGpuPod ¶ Uses

func ScheduleGpuPod(f *framework.Framework, id string, gpuType string, gpuLimit int64) error

ScheduleGpuPod schedules a pod which requires a given number of gpus of given type

func WaitForClusterSizeFunc ¶ Uses

func WaitForClusterSizeFunc(c clientset.Interface, sizeFunc func(int) bool, timeout time.Duration) error

WaitForClusterSizeFunc waits until the cluster size matches the given function.

func WaitForClusterSizeFuncWithUnready ¶ Uses

func WaitForClusterSizeFuncWithUnready(c clientset.Interface, sizeFunc func(int) bool, timeout time.Duration, expectedUnready int) error

WaitForClusterSizeFuncWithUnready waits until the cluster size matches the given function and assumes some unready nodes.

type CriticalAddonsOnlyError ¶ Uses

type CriticalAddonsOnlyError struct{}

CriticalAddonsOnlyError implements the `error` interface, and signifies the presence of the `CriticalAddonsOnly` taint on the node.

func (CriticalAddonsOnlyError) Error ¶ Uses

func (CriticalAddonsOnlyError) Error() string

type CustomMetricTestCase ¶ Uses

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

CustomMetricTestCase is a struct for test cases.

func (*CustomMetricTestCase) Run ¶ Uses

func (tc *CustomMetricTestCase) Run()

Run starts test case.

type DNSParamsLinear ¶ Uses

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

DNSParamsLinear is a struct for number of DNS pods.

type HPAScaleTest ¶ Uses

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

HPAScaleTest struct is used by the scale(...) function.