package e2e_node

import "k8s.io/kubernetes/test/e2e_node"

e2e_node contains e2e tests specific to the node TODO: rename this package e2e-node

Index ¶

• Constants
• Variables
• func PrePullAllImages() error
• func SIGDescribe(text string, body func()) bool
• type ConformanceContainer
• func (cc *ConformanceContainer) Create()
• func (cc *ConformanceContainer) Delete() error
• func (cc *ConformanceContainer) GetPhase() (v1.PodPhase, error)
• func (cc *ConformanceContainer) GetStatus() (v1.ContainerStatus, error)
• func (cc *ConformanceContainer) IsReady() (bool, error)
• func (cc *ConformanceContainer) Present() (bool, error)
• type ContainerState
• func GetContainerState(state v1.ContainerState) ContainerState
• type ResourceCollector
• func NewResourceCollector(interval time.Duration) *ResourceCollector
• func (r *ResourceCollector) GetBasicCPUStats(containerName string) map[float64]float64
• func (r *ResourceCollector) GetCPUSummary() framework.ContainersCPUSummary
• func (r *ResourceCollector) GetLatest() (framework.ResourceUsagePerContainer, error)
• func (r *ResourceCollector) GetResourceTimeSeries() map[string]*perftype.ResourceSeries
• func (r *ResourceCollector) LogLatest()
• func (r *ResourceCollector) Reset()
• func (r *ResourceCollector) Start()
• func (r *ResourceCollector) Stop()

Constants ¶

const (
	TimeSeriesTag = "[Result:TimeSeries]"
	TimeSeriesEnd = "[Finish:TimeSeries]"
)

Variables ¶

var NodeImageWhiteList = sets.NewString(
	"google/cadvisor:latest",
	"gcr.io/google-containers/stress:v1",
	busyboxImage,
	"gcr.io/google_containers/busybox@sha256:4bdd623e848417d96127e16037743f0cd8b528c026e9175e22a84f639eca58ff",
	"gcr.io/google_containers/node-problem-detector:v0.4.1",
	imageutils.GetE2EImage(imageutils.NginxSlim),
	imageutils.GetE2EImage(imageutils.ServeHostname),
	imageutils.GetE2EImage(imageutils.Netexec),
	imageutils.GetE2EImage(imageutils.Nonewprivs),
	framework.GetPauseImageNameForHostArch(),
	framework.GetGPUDevicePluginImage(),
)

NodeImageWhiteList is a list of images used in node e2e test. These images will be prepulled before test running so that the image pulling won't fail in actual test.

Functions ¶

func PrePullAllImages ¶

func PrePullAllImages() error

Pre-fetch all images tests depend on so that we don't fail in an actual test.

func SIGDescribe ¶

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

Types ¶

type ConformanceContainer ¶

type ConformanceContainer struct {
	Container        v1.Container
	RestartPolicy    v1.RestartPolicy
	Volumes          []v1.Volume
	ImagePullSecrets []string

	PodClient *framework.PodClient

	PodSecurityContext *v1.PodSecurityContext
	// contains filtered or unexported fields
}

One pod one container TODO: This should be migrated to the e2e framework.

func (*ConformanceContainer) Create ¶

func (cc *ConformanceContainer) Create()

func (*ConformanceContainer) Delete ¶

func (cc *ConformanceContainer) Delete() error

func (*ConformanceContainer) GetPhase ¶

func (cc *ConformanceContainer) GetPhase() (v1.PodPhase, error)

func (*ConformanceContainer) GetStatus ¶

func (cc *ConformanceContainer) GetStatus() (v1.ContainerStatus, error)

func (*ConformanceContainer) IsReady ¶

func (cc *ConformanceContainer) IsReady() (bool, error)

func (*ConformanceContainer) Present ¶

func (cc *ConformanceContainer) Present() (bool, error)

type ContainerState ¶

type ContainerState string

const (
	ContainerStateWaiting    ContainerState = "Waiting"
	ContainerStateRunning    ContainerState = "Running"
	ContainerStateTerminated ContainerState = "Terminated"
	ContainerStateUnknown    ContainerState = "Unknown"
)

func GetContainerState ¶

func GetContainerState(state v1.ContainerState) ContainerState

type ResourceCollector ¶

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

func NewResourceCollector ¶

func NewResourceCollector(interval time.Duration) *ResourceCollector

NewResourceCollector creates a resource collector object which collects resource usage periodically from Cadvisor

func (*ResourceCollector) GetBasicCPUStats ¶

func (r *ResourceCollector) GetBasicCPUStats(containerName string) map[float64]float64

GetBasicCPUStats returns the percentiles the cpu usage in cores for containerName. This method examines all data currently in the buffer.

func (*ResourceCollector) GetCPUSummary ¶

func (r *ResourceCollector) GetCPUSummary() framework.ContainersCPUSummary

GetCPUSummary gets CPU usage in percentile.

func (*ResourceCollector) GetLatest ¶

func (r *ResourceCollector) GetLatest() (framework.ResourceUsagePerContainer, error)

GetLatest gets the latest resource usage from stats buffer.

func (*ResourceCollector) GetResourceTimeSeries ¶

func (r *ResourceCollector) GetResourceTimeSeries() map[string]*perftype.ResourceSeries

GetResourceSeriesWithLabels gets the time series of resource usage of each container.

func (*ResourceCollector) LogLatest ¶

func (r *ResourceCollector) LogLatest()

LogLatest logs the latest resource usage.

func (*ResourceCollector) Reset ¶

func (r *ResourceCollector) Reset()

Reset clears the stats buffer of resource collector.

func (*ResourceCollector) Start ¶

func (r *ResourceCollector) Start()

Start starts resource collector and connects to the standalone Cadvisor pod then repeatedly runs collectStats.

func (*ResourceCollector) Stop ¶

func (r *ResourceCollector) Stop()

Stop stops resource collector collecting stats. It does not clear the buffer

Source Files ¶

benchmark_util.go container.go doc.go docker_util.go framework.go gpu_device_plugin.go gpus.go image_list.go node_problem_detector_linux.go resource_collector.go simple_mount.go util.go

Directories ¶