e2e

Documentation

Index

• func BadEvents(events []*api.Event) int
• func CheckCadvisorHealthOnAllNodes(c *client.Client, timeout time.Duration)
• func ClusterLevelLoggingWithElasticsearch(c *client.Client)
• func DeleteRC(c *client.Client, ns, name string) error
• func Failf(format string, a ...interface{})
• func HighLatencyRequests(c *client.Client, threshold time.Duration) (int, error)
• func LaunchNetTestPodPerNode(nodes *api.NodeList, name string, c *client.Client, ns string) []string
• func Logf(format string, a ...interface{})
• func RunE2ETests(context *TestContextType, orderseed int64, times int, reportDir string, ...)
• func RunRC(c *client.Client, name string, ns, image string, replicas int) error
• func SSH(cmd, host, provider string) (string, string, int, error)
• func ServeImageOrFail(c *client.Client, test string, image string)
• func VerifyContainersAreNotFailed(pod api.Pod) error
• type CloudConfig
• type LatencyMetric
  • func ReadLatencyMetrics(c *client.Client) ([]LatencyMetric, error)
• type TestContextType

Functions

func BadEvents

func BadEvents(events []*api.Event) int

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

func CheckCadvisorHealthOnAllNodes

func CheckCadvisorHealthOnAllNodes(c *client.Client, timeout time.Duration)

func ClusterLevelLoggingWithElasticsearch

func ClusterLevelLoggingWithElasticsearch(c *client.Client)

ClusterLevelLoggingWithElasticsearch is an end to end test for cluster level logging.

func DeleteRC

func DeleteRC(c *client.Client, ns, name string) error

Delete a Replication Controller and all pods it spawned

func Failf

func Failf(format string, a ...interface{})

func HighLatencyRequests

func HighLatencyRequests(c *client.Client, threshold time.Duration) (int, error)

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

func LaunchNetTestPodPerNode

func LaunchNetTestPodPerNode(nodes *api.NodeList, name string, c *client.Client, ns string) []string

func Logf

func Logf(format string, a ...interface{})

func RunE2ETests

func RunE2ETests(context *TestContextType, orderseed int64, times int, reportDir string, testList []string)

Run each Go end-to-end-test. This function assumes the creation of a test cluster.

func RunRC

func RunRC(c *client.Client, name string, ns, image string, replicas int) error

Launch a Replication Controller and wait for all pods it spawns to become running. The controller will need to be cleaned up external to this method

func SSH

func SSH(cmd, host, provider string) (string, string, int, error)

SSH synchronously SSHs to a node running on provider and runs cmd. If there is no error performing the SSH, the stdout, stderr, and exit code are returned.

func ServeImageOrFail

func ServeImageOrFail(c *client.Client, test string, image string)

A basic test to check the deployment of an image using a replication controller. The image serves its hostname which is checked for each replica.

func VerifyContainersAreNotFailed

func VerifyContainersAreNotFailed(pod api.Pod) error

Types

type CloudConfig

type CloudConfig struct {
	ProjectID  string
	Zone       string
	MasterName string

	Provider cloudprovider.Interface
}

type LatencyMetric

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

LatencyMetrics stores data about request latency at a given quantile broken down by verb (e.g. GET, PUT, LIST) and resource (e.g. pods, services).

func ReadLatencyMetrics

func ReadLatencyMetrics(c *client.Client) ([]LatencyMetric, error)

type TestContextType

type TestContextType struct {
	KubeConfig  string
	KubeContext string
	AuthConfig  string
	CertDir     string
	Host        string
	RepoRoot    string
	Provider    string
	CloudConfig CloudConfig
}