README
¶
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
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 ConformanceImage
- type ContainerState
- type NodeTimeSeries
- type 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 ImageRegistry = map[int]string{
// contains filtered or unexported fields
}
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) 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)
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) List ¶ added in v1.3.0
func (ci *ConformanceImage) List() ([]string, 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.
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
¶
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
|
|
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> |