AddCleanupAction installs a function that will be called in the event of the whole test being terminated.

Checks whether all registered nodes are ready.

ApiCallToPerfData transforms APIResponsiveness to PerfData.

Asserts that cleanup of a namespace wrt selectors occurred.

The following helper functions can block/unblock network from source host to destination host by manipulating iptable rules.

CheckConnectivityToHost launches a pod running wget on the specified node to test connectivity to the specified host.

CheckNewRSAnnotations check if the new RS's annotation is as expected.

CheckNodesReady waits up to nt for expect nodes accessed by c to be ready, returning an error if this doesn't happen in time.

CheckPodsCondition returns whether all pods whose names are listed in podNames in namespace ns are in the condition, using c and waiting at most timeout.

CheckPodsRunningReady returns whether all pods whose names are listed in podNames in namespace ns are running and ready, using c and waiting at most timeout.

CheckPodsRunningReadyOrSucceeded returns whether all pods whose names are listed in podNames in namespace ns are running and ready, or succeeded; use c and waiting at most timeout.

CheckTestingNSDeletedExcept checks whether all e2e based existing namespaces are in the Terminating state and waits until they are finally deleted.

Stops everything from filePath from namespace ns and checks if everything matching selectors from the given namespace is correctly stopped.

CoreDump SSHs to the master and all nodes and dumps their logs into dir.

CPUUsageToPerfData transforms NodesCPUSummary to PerfData.

CPUUsageToPerfDataWithLabels transforms NodesCPUSummary to PerfData with additional labels.

CreateTestingNS should be used by every test, note that we append a common prefix to the provided test name.

DeleteNamespaces deletes all namespaces that match the given delete and skip filters.

DeleteRCAndPods a Replication Controller and all pods it spawned.

DeleteRCAndWaitForGC deletes only the Replication Controller and waits for GC to delete the pods.

Delete a ReplicaSet and all pods it spawned.

EnsureLoadBalancerResourcesDeleted ensures that cloud load balancer resources that were created are actually cleaned up.

Filters nodes in NodeList in place, removing nodes that do not satisfy the given condition TODO: consider merging with pkg/client/cache.NodeLister.

FormatRuntimeOperationErrorRate formats the runtime operation error rate to string.

GetHostExternalAddress gets the node for a pod and returns the first External address.

GetKubeletLatencyMetrics gets all latency related kubelet metrics.

GetKubeletPods retrieves the list of pods on the kubelet.

GetKubeletRunningPods retrieves the list of running pods on the kubelet.

GetMasterAddress returns the hostname/external IP/internal IP as appropriate for e2e tests on a particular provider which is the address of the interface used for communication with the kubelet.

GetMasterAndWorkerNodesOrDie will return a list masters and schedulable worker nodes.

GetNodeExternalIP returns node external IP concatenated with port 22 for ssh e.g.

GetNodePortURL returns the url to a nodeport Service.

GetPauseImageName fetches the pause image name for the same architecture as the apiserver.

GetPauseImageNameForHostArch fetches the pause image name for the same architecture the test is running on.

TODO(random-liu): Change this to be a member function of the framework.

GetPodsScheduled returns a number of currently scheduled and not scheduled Pods.

GetReadySchedulableNodesOrDie addresses the common use case of getting nodes you can do work on.

GetServerArchitecture fetches the architecture of the cluster's apiserver.

GetSigner returns an ssh.Signer for the provider ("gce", etc.) that can be used to SSH to their nodes.

GetValidDNSSubdomainName massages the given name to be a valid dns subdomain name.

HighLatencyKubeletOperations logs and counts the high latency metrics exported by the kubelet server via /metrics.

Prints top five summary metrics for request types with latency and returns number of such request types above threshold.

KubectlCmd runs the kubectl executable through the wrapper script.

KubectlVersion gets the version of kubectl that's currently being used (see --kubectl-path in e2e.go to use an alternate kubectl).

KubectlVersionGTE returns true if the kubectl version is greater than or equal to v.

Wrapper function for ginkgo describe.

LaunchHostExecPod launches a hostexec pod in the given namespace and waits until it's Running.

LaunchWebserverPod launches a pod serving http on port 8080 to act as the target for networking connectivity checks.

LogSuspiciousLatency logs metrics/docker errors from all nodes that had slow startup times If latencyDataLag is nil then it will be populated from latencyData.

Looks for the given string in the output of fn, repeatedly calling fn until the timeout is reached or the string is found.

Looks for the given string in a file in a specific pod container.

Looks for the given string in the log of a specific pod container.

Looks for the given string in the output of a command executed in a specific pod container.

MigTemplate (GCE-only) returns the name of the MIG template that the nodes of the cluster use.

NewNetworkingTestNodeE2EConfig creates and sets up a new test config helper for Node E2E.

NewFramework makes a new framework and sets up a BeforeEach/AfterEach for you (you can write additional before/after each functions).

NewHostExecPodSpec returns the pod spec of hostexec pod.

NewLogsVerifier creates a new LogsSizeVerifier which will stop when stopChannel is closed.

NewNetworkingTestConfig creates and sets up a new test config helper.

NodeAddresses returns the first address of the given type of each node.

NodeProxyRequest performs a get on a node proxy endpoint given the nodename and rest client.

NodeSSHHosts returns SSH-able host names for all schedulable nodes - this excludes master node.

OpenWebSocketForURL constructs a websocket connection to the provided URL, using the client config, with the specified protocols.

ParseKVLines parses output that looks like lines containing "<key>: <val>" and returns <val> if <key> is found.

PrintPerfData prints the perfdata in json format with PerfResultTag prefix.

ReadOrDie reads a file from gobindata.

Register flags specific to the cluster e2e test suite.

Register flags common to all e2e test suites.

Register flags specific to the node e2e test suite.

RemoveCleanupAction removes a function that was installed by AddCleanupAction.

RemoveLabelOffNode is for cleaning up labels temporarily added to node, won't fail if target label doesn't exist or has been removed.

RemoveTaintOffNode is for cleaning up taints temporarily added to node, won't fail if target taint doesn't exist or has been removed.

Resets latency metrics in apiserver.

ResourceUsageToPerfData transforms ResourceUsagePerNode to PerfData.

ResourceUsageToPerfDataWithLabels transforms ResourceUsagePerNode to PerfData with additional labels.

RunCleanupActions runs all functions installed by AddCleanupAction.

RunCmd runs cmd using args and returns its stdout and stderr.

RunHostCmd runs the given cmd in the context of the given pod using `kubectl exec` inside of a shell.

RunHostCmdOrDie calls RunHostCmd and dies on error.

RunKubectl is a convenience wrapper over kubectlBuilder.

RunKubectlOrDie is a convenience wrapper over kubectlBuilder.

RunKubectlOrDieInput is a convenience wrapper over kubectlBuilder that takes input to stdin.

Run a test container to try and contact the Kubernetes api-server from a pod, wait for it to flip to Ready, log its output and delete it.

ScaleRCByLabels scales an RC via ns/label lookup.

ServerVersionGTE returns true if v is greater than or equal to the server version.

Detects whether the federation namespace exists in the underlying cluster.

SSH synchronously SSHs to a node running on provider and runs cmd.

A list of containers for which we want to collect resource usage.

Rough equivalent of ctrl+c for cleaning up processes.

ValidateController is a generic mechanism for testing RC's that are running.

Verifies whether 50, 90 and 99th percentiles of PodStartupLatency are within the threshold.

Verifies (currently just by logging them) the scheduling latencies.

ViperizeFlags sets up all flag and config processing.

checks whether all registered nodes are ready and all required Pods are running on them.

WaitForClusterSize waits until the cluster has desired size and there is no not-ready nodes in it.

WaitForDefaultServiceAccountInNamespace waits for the default service account to be provisioned the default service account is what is associated with pods when they do not specify a service account as a result, pods are not able to be provisioned in a namespace until the service account is provisioned.

Waits for the deployment to clean up old rcs.

WaitForDeploymentRevisionAndImage waits for the deployment's and its new RS's revision and container image to match the given revision and image.

WaitForDeploymentRollbackCleared waits for given deployment either started rolling back or doesn't need to rollback.

Waits for the deployment to reach desired state.

Waits for the deployment status to become valid (i.e.

WaitForDeploymentUpdatedReplicasLTE waits for given deployment to be observed by the controller and has at least a number of updatedReplicas.

Waits for the number of events on the given object to reach a desired count.

WaitForFederationApiserverReady waits for the federation apiserver to be ready.

WaitForIngressAddress waits for the Ingress to acquire an address.

WaitForMatchPodsCondition finds match pods based on the input ListOptions.

WaitForNodeToBe returns whether node "name's" condition state matches wantTrue within timeout.

WaitForNodeToBeNotReady returns whether node name is not ready (i.e.

WaitForNodeToBeReady returns whether node name is ready within timeout.

Waits for the number of events on the given object to be at least a desired count.

WaitForPersistentVolumeClaimPhase waits for a PersistentVolumeClaim to be in a specific phase or until timeout occurs, whichever comes first.

WaitForPersistentVolumeDeleted waits for a PersistentVolume to get deleted or until timeout occurs, whichever comes first.

WaitForPersistentVolumePhase waits for a PersistentVolume to be in a specific phase or until timeout occurs, whichever comes first.

Waits default amount of time (PodStartTimeout) for the specified pod to become running.

Waits default amount of time (podNoLongerRunningTimeout) for the specified pod to stop running.

WaitForPodNotPending returns an error if it took too long for the pod to go out of pending state.

Waits default amount of time (PodStartTimeout) for the specified pod to become running.

WaitForPodsRunningReady waits up to timeout to ensure that all pods in namespace ns are either running and ready, or failed but controlled by a replication controller.

WaitForPodsSuccess waits till all labels matching the given selector enter the Success state.

WaitForPodSuccessInNamespace returns nil if the pod reached state success, or an error if it reached failure or until podStartupTimeout.

WaitForPodSuccessInNamespaceSlow returns nil if the pod reached state success, or an error if it reached failure or until slowPodStartupTimeout.

Wait up to PodListTimeout for getting pods with certain label.

Wait for all matching pods to become scheduled and at least one matching pod exists.

Wait up to 10 minutes for pods to become Running.

WaitForRCPodToDisappear returns nil if the pod from the given replication controller (described by rcName) no longer exists.

WaitForRCToStabilize waits till the RC has a matching generation/replica count between spec and status.

WaitForReplicationController waits until the RC appears (exist == true), or disappears (exist == false).

WaitForService waits until the service appears (exist == true), or disappears (exist == false).

WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.

WaitForStableCluster waits until all existing pods are scheduled and returns their amount.

How long claims have to become dynamically provisioned.

If there are any orphaned namespaces to clean up, this test is running on a long lived cluster.

How long nodes have to be "ready" when a test begins.

Default time to wait for nodes to become schedulable.

NodeStartupThreshold is a rough estimate of the time allocated for a pod to start on a node.

How long to wait for the pod to be listable.

How long pods have to be "ready" when a test begins.

Initial pod start can be delayed O(minutes) by slow docker pulls TODO: Make this 30 seconds once #4566 is resolved.

How often to Poll pods, nodes and claims.

How long a node is allowed to become "Ready" after it is restarted before the test is considered failed.

How long each node is given during a process that restarts all nodes before the test is considered failed.

How long a pod is allowed to become "running" and "ready" after a node restart before test is considered failed.

How often to Poll the statues of a restart.

service accounts are provisioned after namespace creation a service account is required to support pod creation in a namespace as part of admission control.

How long to wait for a service endpoint to be resolvable.

How long to try single API calls (like 'get' or 'list').

Number of times we want to retry Updates in case of conflict.

Label allocated to the image puller static pod that runs on each node before e2es.

ImageWhiteList is the images used in the current test suite.

The following upgrade functions are passed into the framework below and used to do the actual upgrades.

ProvidersWithSSH are those providers where each node is accessible with SSH.

unique identifier of the e2e run.

SubResource proxy should have been functional in v1.0.0, but SubResource proxy via tunneling is known to be broken in v1.0.

E2ETestNodePreparer implements testutils.TestNodePreparer interface, which is used to create/modify Nodes before running a test.

Framework supports common operations used by e2e tests; it will keep a client & a namespace for you.

KubeletMetric stores metrics scraped from the kubelet server's /metric endpoint.

Dashboard metrics.

LogSizeGatherer is a worker which grabs a WorkItem from the channel and does assigned work.

LogsSizeVerifier gathers data about log files sizes from master and node machines.

NetworkingTestConfig is a convenience class around some utility methods for testing kubeproxy/networking/services/endpoints.

NodeTestContextType is part of TestContextType, it is shared by all node e2e test.

PodLatencyData encapsulates pod startup latency information.

PodStateVerification represents a verification of pod state.

ResourceMonitor manages a resourceCollector per node.

RuntimeOperationErrorRate is the error rate of a specified runtime operation.

RuntimeOperationMonitor is the tool getting and parsing docker operation metrics.

TimestampedSize contains a size together with a time of measurement.

WorkItem is a command for a worker that contains an IP of machine from which we want to gather data and paths to all files we're interested in.

ContainersCPUSummary is indexed by the container name with each entry a (percentile, value) map.

KubeletMetricByLatency implements sort.Interface for []KubeletMetric based on the latency field.

node -> file -> data.

NodeRuntimeOperationErrorRate is the runtime operation error rate on one node.

NodesCPUSummary is indexed by the node name with each entry a ContainersCPUSummary map.

we can't have int here, as JSON does not accept integer keys.