common

package
v1.7.2-beta.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2017 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KindRC         = "ReplicationController"
	KindDeployment = "Deployment"
	KindReplicaSet = "ReplicaSet"
)

Variables

View Source
var AppArmorDistros = []string{"gci", "ubuntu"}

AppArmorDistros are distros with AppArmor support

View Source
var CommonImageWhiteList = sets.NewString(
	"gcr.io/google_containers/busybox:1.24",
	"gcr.io/google_containers/eptest:0.1",
	"gcr.io/google_containers/liveness:e2e",
	"gcr.io/google_containers/mounttest:0.8",
	"gcr.io/google_containers/mounttest-user:0.5",
	"gcr.io/google_containers/netexec:1.4",
	"gcr.io/google_containers/netexec:1.5",
	"gcr.io/google_containers/nginx-slim:0.7",
	"gcr.io/google_containers/serve_hostname:v1.4",
	"gcr.io/google_containers/test-webserver:e2e",
	"gcr.io/google_containers/hostexec:1.2",
	"gcr.io/google_containers/volume-nfs:0.8",
	"gcr.io/google_containers/volume-gluster:0.2",
)

CommonImageWhiteList is the list of images used in common test. These images should be prepulled before a tests starts, so that the tests won't fail due image pulling flakes. Currently, this is only used by node e2e test. TODO(random-liu): Change the image puller pod to use similar mechanism.

Functions

func CreateAppArmorTestPod added in v1.6.0

func CreateAppArmorTestPod(f *framework.Framework, runOnce bool) *api.Pod

CreateAppArmorTestPod creates a pod that tests apparmor profile enforcement. The pod exits with an error code if the profile is incorrectly enforced. If runOnce is true the pod will exit after a single test, otherwise it will repeat the test every 1 second until failure.

func CreateCPUHorizontalPodAutoscaler added in v1.6.0

func CreateCPUHorizontalPodAutoscaler(rc *ResourceConsumer, cpu, minReplicas, maxRepl int32) *autoscalingv1.HorizontalPodAutoscaler

func DeleteHorizontalPodAutoscaler added in v1.7.0

func DeleteHorizontalPodAutoscaler(rc *ResourceConsumer, autoscalerName string)

func GetResourceConsumerImage added in v1.6.0

func GetResourceConsumerImage() string

func LoadAppArmorProfiles added in v1.6.0

func LoadAppArmorProfiles(f *framework.Framework)

func ObserveEventAfterAction added in v1.6.0

func ObserveEventAfterAction(f *framework.Framework, eventPredicate func(*v1.Event) bool, action Action) (bool, error)

Returns true if an event matching the predicate was emitted from the system after performing the supplied action.

func ObserveNodeUpdateAfterAction added in v1.6.0

func ObserveNodeUpdateAfterAction(f *framework.Framework, nodeName string, nodePredicate func(*v1.Node) bool, action Action) (bool, error)

Returns true if a node update matching the predicate was emitted from the system after performing the supplied action.

func SkipIfAppArmorNotSupported added in v1.6.0

func SkipIfAppArmorNotSupported()

Types

type Action added in v1.6.0

type Action func() error

type KubeletManagedHostConfig

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

type PrivilegedPodTestConfig

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

type ResourceConsumer added in v1.6.0

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

ResourceConsumer is a tool for testing. It helps create specified usage of CPU or memory (Warning: memory not supported) typical use case: rc.ConsumeCPU(600) // ... check your assumption here rc.ConsumeCPU(300) // ... check your assumption here

func NewDynamicResourceConsumer added in v1.6.0

func NewDynamicResourceConsumer(name, kind string, replicas, initCPUTotal, initMemoryTotal, initCustomMetric int, cpuLimit, memLimit int64, f *framework.Framework) *ResourceConsumer

func NewStaticResourceConsumer added in v1.6.0

func NewStaticResourceConsumer(name string, replicas, initCPUTotal, initMemoryTotal, initCustomMetric int, cpuLimit, memLimit int64, f *framework.Framework) *ResourceConsumer

TODO this still defaults to replication controller

func (*ResourceConsumer) CleanUp added in v1.6.0

func (rc *ResourceConsumer) CleanUp()

func (*ResourceConsumer) ConsumeCPU added in v1.6.0

func (rc *ResourceConsumer) ConsumeCPU(millicores int)

ConsumeCPU consumes given number of CPU

func (*ResourceConsumer) ConsumeCustomMetric added in v1.6.0

func (rc *ResourceConsumer) ConsumeCustomMetric(amount int)

ConsumeMem consumes given number of custom metric

func (*ResourceConsumer) ConsumeMem added in v1.6.0

func (rc *ResourceConsumer) ConsumeMem(megabytes int)

ConsumeMem consumes given number of Mem

func (*ResourceConsumer) EnsureDesiredReplicas added in v1.6.0

func (rc *ResourceConsumer) EnsureDesiredReplicas(desiredReplicas int, duration time.Duration)

func (*ResourceConsumer) GetReplicas added in v1.6.0

func (rc *ResourceConsumer) GetReplicas() int

func (*ResourceConsumer) Pause added in v1.6.0

func (rc *ResourceConsumer) Pause()

Pause stops background goroutines responsible for consuming resources.

func (*ResourceConsumer) Resume added in v1.6.0

func (rc *ResourceConsumer) Resume()

Pause starts background goroutines responsible for consuming resources.

func (*ResourceConsumer) WaitForReplicas added in v1.6.0

func (rc *ResourceConsumer) WaitForReplicas(desiredReplicas int, duration time.Duration)

type Suite

type Suite string
const (
	E2E           Suite = "e2e"
	NodeE2E       Suite = "node e2e"
	FederationE2E Suite = "federation e2e"
)
var CurrentSuite Suite

Jump to

Keyboard shortcuts

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