e2e_node

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2016 License: Apache-2.0 Imports: 35 Imported by: 0

README

WARNING WARNING WARNING WARNING WARNING

PLEASE NOTE: This document applies to the HEAD of the source tree

If you are using a released version of Kubernetes, you should refer to the docs that go with that version.

The latest release of this document can be found [here](http://releases.k8s.io/release-1.1/docs/devel/collab.md).

Documentation for other releases can be found at releases.k8s.io.

See e2e-node-tests

Analytics

Documentation

Overview

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

Index

Constants

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

Variables

View Source 
var ImageRegistry = map[int]string{
	// contains filtered or unexported fields
}
View Source 
var NoPullImageRegistry = map[int]string{
	// contains filtered or unexported fields
}

These are used by tests that explicitly test the ability to pull images

Functions

func PrePullAllImages added in v1.3.0 

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 added in v1.3.0 

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

func (*ConformanceContainer) GetStatus added in v1.3.0 

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

func (*ConformanceContainer) IsReady added in v1.3.0 

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

func (*ConformanceContainer) Present added in v1.3.0 

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

type ConformanceImage added in v1.3.0 

type ConformanceImage struct {
	Image   kubecontainer.ImageSpec
	Runtime kubecontainer.Runtime
}

func NewConformanceImage added in v1.3.0 

func NewConformanceImage(containerRuntime string, image string) (ci ConformanceImage, err error)

func (*ConformanceImage) GetTag added in v1.3.0 

func (ci *ConformanceImage) GetTag() string

func (*ConformanceImage) List added in v1.3.0 

func (ci *ConformanceImage) List() ([]string, error)

func (*ConformanceImage) Present added in v1.3.0 

func (ci *ConformanceImage) Present() (bool, error)

func (*ConformanceImage) Pull added in v1.3.0 

func (ci *ConformanceImage) Pull() error

func (*ConformanceImage) Remove added in v1.3.0 

func (ci *ConformanceImage) Remove() error

type ContainerState added in v1.3.0 

type ContainerState int
const (
	ContainerStateWaiting ContainerState = iota
	ContainerStateRunning
	ContainerStateTerminated
	ContainerStateUnknown
)

func GetContainerState added in v1.3.0 

func GetContainerState(state api.ContainerState) ContainerState

type NodeTimeSeries added in v1.4.0 

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 added in v1.4.0 

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

func NewResourceCollector added in v1.4.0 

func NewResourceCollector(interval time.Duration) *ResourceCollector

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

func (*ResourceCollector) GetBasicCPUStats added in v1.4.0 

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 added in v1.4.0 

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

GetCPUSummary gets CPU usage in percentile.

func (*ResourceCollector) GetLatest added in v1.4.0 

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

GetLatest gets the latest resource usage from stats buffer.

func (*ResourceCollector) GetResourceTimeSeries added in v1.4.0 

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

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

func (*ResourceCollector) LogLatest added in v1.4.0 

func (r *ResourceCollector) LogLatest()

LogLatest logs the latest resource usage.

func (*ResourceCollector) Reset added in v1.4.0 

func (r *ResourceCollector) Reset()

Reset clears the stats buffer of resource collector.

func (*ResourceCollector) Start added in v1.4.0 

func (r *ResourceCollector) Start()

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

func (*ResourceCollector) Stop added in v1.4.0 

func (r *ResourceCollector) Stop()

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

type ResourceSeries added in v1.4.0 

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

Source Files

View all Source files

Directories

Path Synopsis
Build the binary with `go build conformance.go`, then run the conformance binary on a node candidate.
 Build the binary with `go build conformance.go`, then run the conformance binary on a node candidate.
runner
local
remote
To run the node e2e tests remotely against one or more hosts on gce: $ go run run_remote.go --logtostderr --v 2 --ssh-env gce --hosts <comma separated hosts> To run the node e2e tests remotely against one or more images on gce and provision them: $ go run run_remote.go --logtostderr --v 2 --project <project> --zone <zone> --ssh-env gce --images <comma separated images>
 To run the node e2e tests remotely against one or more hosts on gce: $ go run run_remote.go --logtostderr --v 2 --ssh-env gce --hosts <comma separated hosts> To run the node e2e tests remotely against one or more images on gce and provision them: $ go run run_remote.go --logtostderr --v 2 --project <project> --zone <zone> --ssh-env gce --images <comma separated images>

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.