e2e_node

README

See e2e-node-tests

Documentation

Overview

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

Index

• Constants
• Variables
• func PrePullAllImages() error
• type ConformanceContainer
  • func (cc *ConformanceContainer) Create()
  • func (cc *ConformanceContainer) Delete() error
  • func (cc *ConformanceContainer) GetPhase() (api.PodPhase, error)
  • func (cc *ConformanceContainer) GetStatus() (api.ContainerStatus, error)
  • func (cc *ConformanceContainer) IsReady() (bool, error)
  • func (cc *ConformanceContainer) Present() (bool, error)
• type ContainerState
  • func GetContainerState(state api.ContainerState) ContainerState
• type NodeTimeSeries
• 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]*ResourceSeries
  • func (r *ResourceCollector) LogLatest()
  • func (r *ResourceCollector) Reset()
  • func (r *ResourceCollector) Start()
  • func (r *ResourceCollector) Stop()
• type ResourceSeries

Constants

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

Variables

var NodeImageWhiteList = sets.NewString(
	"google/cadvisor:latest",
	"gcr.io/google-containers/stress:v1",
	"gcr.io/google_containers/busybox:1.24",
	"gcr.io/google_containers/busybox@sha256:4bdd623e848417d96127e16037743f0cd8b528c026e9175e22a84f639eca58ff",
	"gcr.io/google_containers/nginx-slim:0.7",
	"gcr.io/google_containers/serve_hostname:v1.4",
	"gcr.io/google_containers/netexec:1.7",
	framework.GetPauseImageNameForHostArch(),
)

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.

Types

type ConformanceContainer

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

	PodClient *framework.PodClient

	PodSecurityContext *api.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() (api.PodPhase, error)

func (*ConformanceContainer) GetStatus

func (cc *ConformanceContainer) GetStatus() (api.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 api.ContainerState) ContainerState

type NodeTimeSeries

type NodeTimeSeries struct {
	// value in OperationData is an array of timestamps
	OperationData map[string][]int64         `json:"op_series,omitempty"`
	ResourceData  map[string]*ResourceSeries `json:"resource_series,omitempty"`
	Labels        map[string]string          `json:"labels"`
	Version       string                     `json:"version"`
}

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]*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

type ResourceSeries

type ResourceSeries struct {
	Timestamp            []int64           `json:"ts"`
	CPUUsageInMilliCores []int64           `json:"cpu"`
	MemoryRSSInMegaBytes []int64           `json:"memory"`
	Units                map[string]string `json:"unit"`
}

Time series of resource usage