autoscaling

Documentation

Index

• Constants
• Variables
• func ReserveMemory(ctx context.Context, f *framework.Framework, id string, ...) func() error
• func ReserveMemoryWithPriority(ctx context.Context, f *framework.Framework, id string, ...) func() error
• func ReserveMemoryWithSchedulerName(ctx context.Context, f *framework.Framework, id string, ...) func() error
• func ReserveMemoryWithSelectorAndTolerations(ctx context.Context, f *framework.Framework, id string, ...) func() error
• func ScheduleAnySingleGpuPod(ctx context.Context, f *framework.Framework, id string) error
• func ScheduleGpuPod(ctx context.Context, f *framework.Framework, id string, gpuType string, ...) error
• func WaitForClusterSizeFunc(ctx context.Context, c clientset.Interface, sizeFunc func(int) bool, ...) error
• func WaitForClusterSizeFuncWithUnready(ctx context.Context, c clientset.Interface, sizeFunc func(int) bool, ...) error
• type CriticalAddonsOnlyError
  • func (CriticalAddonsOnlyError) Error() string
• type CustomMetricTestCase
  • func (tc *CustomMetricTestCase) Run(ctx context.Context)
• type DNSParamsLinear
• type HPAContainerResourceScaleTest
• type HPAScaleTest

Constants

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

Constants used in dns-autoscaling test.

Variables

var SIGDescribe = framework.SIGDescribe("autoscaling")

SIGDescribe annotates the test with the SIG label.

Functions

func ReserveMemory

func ReserveMemory(ctx context.Context, 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

func ReserveMemoryWithPriority(ctx context.Context, 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 ReserveMemoryWithSchedulerName

func ReserveMemoryWithSchedulerName(ctx context.Context, f *framework.Framework, id string, replicas, megabytes int, expectRunning bool, timeout time.Duration, schedulerName string) func() error

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

func ReserveMemoryWithSelectorAndTolerations

func ReserveMemoryWithSelectorAndTolerations(ctx context.Context, 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 ScheduleAnySingleGpuPod

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

ScheduleAnySingleGpuPod schedules a pod which requires single GPU of any type

func ScheduleGpuPod

func ScheduleGpuPod(ctx context.Context, 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

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

WaitForClusterSizeFunc waits until the cluster size matches the given function.

func WaitForClusterSizeFuncWithUnready

func WaitForClusterSizeFuncWithUnready(ctx context.Context, 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.

Types

type CriticalAddonsOnlyError

type CriticalAddonsOnlyError struct{}

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

func (CriticalAddonsOnlyError) Error

func (CriticalAddonsOnlyError) Error() string

type CustomMetricTestCase

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

CustomMetricTestCase is a struct for test cases.

func (*CustomMetricTestCase) Run

func (tc *CustomMetricTestCase) Run(ctx context.Context)

Run starts test case.

type DNSParamsLinear

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

DNSParamsLinear is a struct for number of DNS pods.

type HPAContainerResourceScaleTest

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

type HPAScaleTest

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

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