package e2enode

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

Package e2enode contains e2e tests specific to the node

Index ¶

• Constants
• Variables
• func IsCgroup2UnifiedMode() bool
• func PrePullAllImages() error
• func SIGDescribe(text string, body func()) bool
• type ResourceCollector
• func NewResourceCollector(interval time.Duration) *ResourceCollector
• func (r *ResourceCollector) GetBasicCPUStats(containerName string) map[float64]float64
• func (r *ResourceCollector) GetCPUSummary() e2ekubelet.ContainersCPUSummary
• func (r *ResourceCollector) GetLatest() (e2ekubelet.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 is the tag for time series.
	TimeSeriesTag = "[Result:TimeSeries]"
	// TimeSeriesEnd is the end tag for time series.
	TimeSeriesEnd = "[Finish:TimeSeries]"
)

const (
	KubeVirtDevicePluginDSYAML = "test/e2e_node/testing-manifests/kubevirt-kvm-ds.yaml"

	// KubeVirtDevicePluginName is the name of the device plugin pod
	KubeVirtDevicePluginName = "kubevirt-device-plugin"

	// KubeVirtResourceName is the name of the resource provided by kubevirt device plugin
	KubeVirtResourceName = "devices.kubevirt.io/kvm"
)

const (
	// SRIOVDevicePluginCMYAML is the path of the config map to configure the sriov device plugin.
	SRIOVDevicePluginCMYAML = "test/e2e_node/testing-manifests/sriovdp-cm.yaml"
	// SRIOVDevicePluginDSYAML is the path of the daemonset template of the sriov device plugin. // TODO: Parametrize it by making it a feature in TestFramework.
	SRIOVDevicePluginDSYAML = "test/e2e_node/testing-manifests/sriovdp-ds.yaml"
	// SRIOVDevicePluginSAYAML is the path of the service account needed by the sriov device plugin to run.
	SRIOVDevicePluginSAYAML = "test/e2e_node/testing-manifests/sriovdp-sa.yaml"
	// SRIOVDevicePluginName is the name of the device plugin pod
	SRIOVDevicePluginName = "sriov-device-plugin"
)

const (

	// SampleDevicePluginDSYAML is the path of the daemonset template of the sample device plugin. // TODO: Parametrize it by making it a feature in TestFramework.
	SampleDevicePluginDSYAML = "test/e2e/testing-manifests/sample-device-plugin.yaml"
)

Variables ¶

var NodePrePullImageList = sets.NewString(
	imageutils.GetE2EImage(imageutils.Agnhost),
	"gcr.io/cadvisor/cadvisor:v0.43.0",
	"registry.k8s.io/stress:v1",
	busyboxImage,
	"registry.k8s.io/busybox@sha256:4bdd623e848417d96127e16037743f0cd8b528c026e9175e22a84f639eca58ff",
	imageutils.GetE2EImage(imageutils.Nginx),
	imageutils.GetE2EImage(imageutils.Perl),
	imageutils.GetE2EImage(imageutils.Nonewprivs),
	imageutils.GetPauseImageName(),
	imageutils.GetE2EImage(imageutils.NodePerfNpbEp),
	imageutils.GetE2EImage(imageutils.NodePerfNpbIs),
	imageutils.GetE2EImage(imageutils.NodePerfTfWideDeep),
	imageutils.GetE2EImage(imageutils.Etcd),
)

NodePrePullImageList 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 IsCgroup2UnifiedMode ¶

func IsCgroup2UnifiedMode() bool

IsCgroup2UnifiedMode returns whether we are running in cgroup v2 unified mode.

func PrePullAllImages ¶

func PrePullAllImages() error

PrePullAllImages pre-fetches all images tests depend on so that we don't fail in an actual test.

func SIGDescribe ¶

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

SIGDescribe annotates the test with the SIG label.

Types ¶

type ResourceCollector ¶

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

ResourceCollector is a collector object which collects resource usage periodically from Cadvisor.

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() e2ekubelet.ContainersCPUSummary

GetCPUSummary gets CPU usage in percentile.

func (*ResourceCollector) GetLatest ¶

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

GetLatest gets the latest resource usage from stats buffer.

func (*ResourceCollector) GetResourceTimeSeries ¶

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

GetResourceTimeSeries 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 checkpoint_container.go doc.go framework.go image_credential_provider.go image_list.go node_problem_detector_linux.go numa_alignment.go resource_collector.go util.go util_kubevirt.go util_sriov.go util_sriov_linux.go util_xfs_linux.go utils_linux.go

Directories ¶