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.

Prints the histogram of the events and returns the number of bad events.

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.

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.

Delete a Replication Controller and all pods it spawned.

Delete a ReplicaSet and all pods it spawned.

Diff computes a PodDiff given 2 lists of pods.

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

FailedContainers inspects all containers in a pod and returns failure information for containers that have failed or been restarted.

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.

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.

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.

MigRollingUpdate starts a MIG rolling update, upgrading the nodes to a new instance template named tmpl, and waits up to nt times the number of nodes for it to complete.

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

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.

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.

PodNotReady checks whether pod p's has a ready condition of status false.

PodRunningReady checks whether pod p's phase is running and it has a ready condition of status true.

PrintPerfData prints the perfdata in json format with PerfResultTag prefix.

ReadOrDie reads a file from gobindata.

RemoveCleanupAction removes a function that was installed by AddCleanupAction.

Resets latency metrics in apiserver.

ResourceUsageToPerfData transforms ResourceUsagePerNode to PerfData.

RunCleanupActions runs all functions installed by AddCleanupAction.

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

RunDeployment Launches (and verifies correctness) of a Deployment and will wait for all pods it spawns to become "Running".

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.

RunRC Launches (and verifies correctness) of a Replication Controller and will wait for all pods it spawns to become "Running".

RunReplicaSet launches (and verifies correctness) of a ReplicaSet and waits until all the pods it launches to reach the "Running" state.

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.

Simplified version of RunRC, that does not create RC, but creates plain Pods.

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

TestContainerOutput runs the given pod in the given namespace and waits for all of the containers in the podSpec to move into the 'Success' status, and tests the specified container log against the given expected output using a substring matcher.

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.

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.

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 (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 up to 10 minutes for all matching pods to become Running and at least one matching pod exists.

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.

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.

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').

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

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.

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.

PodLatencyData encapsulates pod startup latency information.

PodStateVerification represents a verification of pod state.

Convenient wrapper around cache.Store that returns list of api.Pod instead of interface{}.

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.

PodDiff is a map of pod name to podInfos.

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