e2e

package

Go to main page

Versions in this module

v1

v1.1.6

Apr 5, 2016

v1.1.6-jenkins-build-config

Apr 29, 2016

v1.1.5

Mar 29, 2016

Changes in this version

+ const MinPodsPerSecondThroughput

+ const MinSaturationThreshold

+ func CheckConnectivityToHost(f *Framework, nodeName, podName, host string) error

+ func CreateTestingNS(baseName string, c *client.Client, labels map[string]string) (*api.Namespace, error)

+ func GetReadyNodes(f *Framework) (nodes *api.NodeList, err error)

+ func GetServicesProxyRequest(c *client.Client, request *restclient.Request) (*restclient.Request, error)

+ func LaunchWebserverPod(f *Framework, podName, nodeName string) (ip string)

+ func NewResourceUsageGatherer(c *client.Client) (*containerResourceGatherer, error)

+ func PrintAllKubeletPods(c *client.Client, nodeName string)

+ func RemoveCleanupAction(p CleanupActionHandle)

+ func RunCleanupActions()

+ func RunReplicaSet(config ReplicaSetConfig) error

+ func SkipUnlessAtLeast(value int, minValue int, message string)

+ func SpreadRCOrFail(f *Framework, replicaCount int, image string)

+ func SpreadServiceOrFail(f *Framework, replicaCount int, image string)

+ type CleanupActionHandle *int

+ func AddCleanupAction(fn func()) CleanupActionHandle

+ type CreateTestingNSFn func(baseName string, c *client.Client, labels map[string]string) (*api.Namespace, error)

type Framework

+ func NewDefaultFramework(baseName string) *Framework

+ func (f *Framework) CreateNamespace(baseName string, labels map[string]string) (*api.Namespace, error)

+ func (f *Framework) WaitForPodNoLongerRunning(podName string) error

+ func (f *Framework) WaitForPodReady(podName string) error

+ type FrameworkOptions struct

type RCConfig

+ HostPorts map[string]int

+ ReadinessProbe *api.Probe

+ VolumeMounts []api.VolumeMount

+ Volumes []api.Volume

+ type ReplicaSetConfig struct

type ResourceConsumer

+ func (rc *ResourceConsumer) ConsumeCustomMetric(amount int)

+ type SaturationTime struct

+ NumberOfNodes int

+ NumberOfPods int

+ Throughput float32

+ TimeToSaturate time.Duration

type TestContextType

+ CreateTestingNS CreateTestingNSFn

v1.1.4

Mar 14, 2016

Changes in this version

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

+ func EnsureLoadBalancerResourcesDeleted(ip, portRange string) error

+ func Query(c *client.Client, query string) (*influxdb.Response, error)

+ func RegisterFlags()

+ func ReplicaSetServeImageOrFail(f *Framework, test string, image string)

+ func RunE2ETests(t *testing.T)

+ func SkipUnlessServerVersionGTE(v semver.Version, c client.ServerVersionInterface)

type Framework

+ Clientset_1_2 *release_1_2.Clientset

+ type ServiceTestFixture struct

+ Client *client.Client

+ Labels map[string]string

+ Namespace string

+ ServiceName string

+ TestId string

+ func (t *ServiceTestFixture) BuildServiceSpec() *api.Service

+ func (t *ServiceTestFixture) Cleanup() []error

+ func (t *ServiceTestFixture) CreateService(service *api.Service) (*api.Service, error)

+ func (t *ServiceTestFixture) CreateWebserverRC(replicas int) *api.ReplicationController

+ func (t *ServiceTestFixture) DeleteService(serviceName string) error

+ type ServiceTestJig struct

+ Client *client.Client

+ ID string

+ Labels map[string]string

+ Name string

+ func NewServiceTestJig(client *client.Client, name string) *ServiceTestJig

+ func (j *ServiceTestJig) ChangeServiceNodePortOrFail(namespace, name string, initial int) *api.Service

+ func (j *ServiceTestJig) CreateTCPServiceOrFail(namespace string, tweak func(svc *api.Service)) *api.Service

+ func (j *ServiceTestJig) CreateUDPServiceOrFail(namespace string, tweak func(svc *api.Service)) *api.Service

+ func (j *ServiceTestJig) RunOrFail(namespace string, tweak func(rc *api.ReplicationController)) *api.ReplicationController

+ func (j *ServiceTestJig) SanityCheckService(svc *api.Service, svcType api.ServiceType)

+ func (j *ServiceTestJig) TestNotReachableHTTP(host string, port int, timeout time.Duration)

+ func (j *ServiceTestJig) TestNotReachableUDP(host string, port int, timeout time.Duration)

+ func (j *ServiceTestJig) TestReachableHTTP(host string, port int, timeout time.Duration)

+ func (j *ServiceTestJig) TestReachableUDP(host string, port int, timeout time.Duration)

+ func (j *ServiceTestJig) UpdateService(namespace, name string, update func(*api.Service)) (*api.Service, error)

+ func (j *ServiceTestJig) UpdateServiceOrFail(namespace, name string, update func(*api.Service)) *api.Service

+ func (j *ServiceTestJig) WaitForLoadBalancerDestroyOrFail(namespace, name string, ip string, port int) *api.Service

+ func (j *ServiceTestJig) WaitForLoadBalancerOrFail(namespace, name string) *api.Service

v1.1.4-jenkins-build-config

Mar 29, 2016

v1.1.3

Feb 17, 2016

Changes in this version

+ var InterestingApiServerMetrics = []string

+ var InterestingKubeletMetrics = []string

+ func ListSchedulableNodesOrDie(c *client.Client) *api.NodeList

type Framework

+ func (f *Framework) WaitForPodTerminated(podName, reason string) error

+ type LogSizeDataTimeseries map[string]map[string][]TimestampedSize

+ type LogsSizeDataSummary map[string]map[string]SingleLogSummary

+ func (s *LogsSizeDataSummary) PrintHumanReadable() string

+ func (s *LogsSizeDataSummary) PrintJSON() string

type LogsSizeVerifier

+ func (s *LogsSizeVerifier) GetSummary() *LogsSizeDataSummary

+ type MetricsForE2E metrics.MetricsCollection

+ func (m *MetricsForE2E) PrintHumanReadable() string

+ func (m *MetricsForE2E) PrintJSON() string

+ type ResourceUsageSummary map[string][]SingleContainerSummary

+ func (s *ResourceUsageSummary) PrintHumanReadable() string

+ func (s *ResourceUsageSummary) PrintJSON() string

+ type ServerTest struct

+ Client *client.Client

+ Labels map[string]string

+ Namespace string

+ ServiceName string

+ TestId string

+ func NewNetcatTest(client *client.Client, namespace string, serviceName string) *ServerTest

+ func NewServerTest(client *client.Client, namespace string, serviceName string) *ServerTest

+ func (t *ServerTest) BuildServiceSpec() *api.Service

+ func (t *ServerTest) Cleanup() []error

+ func (t *ServerTest) CreateNetcatRC(replicas int) *api.ReplicationController

+ func (t *ServerTest) CreateService(service *api.Service) (*api.Service, error)

+ func (t *ServerTest) CreateWebserverRC(replicas int) *api.ReplicationController

+ func (t *ServerTest) DeleteService(serviceName string) error

+ type SingleContainerSummary struct

+ Cpu float64

+ Mem int64

+ Name string

+ type SingleLogSummary struct

+ AverageGenerationRate int

+ NumberOfProbes int

type TestContextType

+ GatherMetricsAfterTest bool

+ KubeVolumeDir string

+ OutputPrintType string

+ ReportDir string

+ type TestDataSummary interface

+ PrintHumanReadable func() string

+ PrintJSON func() string

v1.1.2

Feb 6, 2016

Changes in this version

+ func LaunchHostExecPod(client *client.Client, ns, name string) *api.Pod

+ func LogSSHResult(result SSHResult)

+ func NewHostExecPodSpec(ns, name string) *api.Pod

+ func NodeAddresses(nodelist *api.NodeList, addrType api.NodeAddressType) []string

+ func RunDeployment(config DeploymentConfig) error

+ func RunHostCmd(ns, name, cmd string) (string, error)

+ func RunHostCmdOrDie(ns, name, cmd string) string

+ func VerifySchedulerLatency() error

type CloudConfig

+ ServiceAccount string

+ type DeploymentConfig struct

type Framework

+ func (f *Framework) WaitForPodRunningSlow(podName string) error

+ type HPAScaleTest struct

+ type IngressController struct

+ Project string

+ UID string

+ func (cont *IngressController) Cleanup(del bool) error

+ type LogSizeGatherer struct

+ func (g *LogSizeGatherer) Run()

+ func (g *LogSizeGatherer) Work() bool

+ type LogsSizeData struct

+ func (d *LogsSizeData) AddNewData(ip, path string, timestamp time.Time, size int)

+ func (d *LogsSizeData) PrintData() string

+ type LogsSizeVerifier struct

+ func NewLogsVerifier(c *client.Client, stopChannel chan bool) *LogsSizeVerifier

+ func (v *LogsSizeVerifier) PrintData() string

+ func (v *LogsSizeVerifier) Run()

type ResourceConsumer

+ func (rc *ResourceConsumer) EnsureDesiredReplicas(desiredReplicas int, timeout time.Duration)

+ type SSHResult struct

+ Cmd string

+ Code int

+ Host string

+ Stderr string

+ Stdout string

+ User string

+ type SchedulingLatency struct

+ Binding LatencyMetric

+ Scheduling LatencyMetric

+ Total LatencyMetric

type TestContextType

+ CleanStart bool

+ DeleteNamespace bool

+ GatherKubeSystemResourceUsageData bool

+ GatherLogsSizes bool

+ type TimestampedSize struct

+ type WorkItem struct

v1.1.1

Jan 18, 2016

v1.0.8

Nov 7, 2015

Changes in this version

+ type KubeletManagedHostConfig struct

v1.0.7

Oct 29, 2015

Changes in this version

+ const ADD

+ const DEL

+ const UPDATE

+ func NewRestartConfig(nodeName, daemonName string, healthzPort int, ...) *restartDaemonConfig

+ func OpenWebSocketForURL(url *url.URL, config *client.Config, protocols []string) (*websocket.Conn, error)

+ func VerifyPodStartupLatency(latency PodStartupLatency, podStartupThreshold time.Duration) error

+ type APICall struct

+ Latency LatencyMetric

+ Resource string

+ Verb string

+ type APIResponsiveness struct

+ APICalls []APICall

+ func (a APIResponsiveness) Len() int

+ func (a APIResponsiveness) Less(i, j int) bool

+ func (a APIResponsiveness) Swap(i, j int)

type Framework

+ NamespaceDeletionTimeout time.Duration

+ func (f *Framework) TestContainerOutputRegexp(scenarioName string, pod *api.Pod, containerIndex int, expectedOutput []string)

+ type KubeProxyTestConfig struct

+ type LBCTester interface

type LatencyMetric

+ Perc50 time.Duration

+ Perc90 time.Duration

+ Perc99 time.Duration

+ type PodStartupLatency struct

+ Latency LatencyMetric

+ type PrivilegedPodTestConfig struct

type RCConfig

+ CpuRequest int64

+ MemRequest int64

+ type ResourceConsumer struct

+ func NewDynamicResourceConsumer(name string, replicas, initCPU, initMemory int, cpuLimit, memLimit int64, ...) *ResourceConsumer

+ func NewStaticResourceConsumer(name string, replicas, initCPU, initMemory int, cpuLimit, memLimit int64, ...) *ResourceConsumer

+ func (rc *ResourceConsumer) CleanUp()

+ func (rc *ResourceConsumer) ConsumeCPU(millicores int)

+ func (rc *ResourceConsumer) ConsumeMem(megabytes int)

+ func (rc *ResourceConsumer) GetReplicas() int

+ func (rc *ResourceConsumer) WaitForReplicas(desiredReplicas int)

type TestContextType

+ VerifyServiceAccount bool

v1.0.6

Sep 13, 2015

v1.0.5

Aug 24, 2015

Changes in this version

+ const NodeStartupThreshold

+ var MaxContainerFailures = 0

+ var ServiceNodePortRange = util.PortRange

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

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

+ func ClusterLevelLoggingWithElasticsearch(f *Framework)

+ func ClusterLevelLoggingWithKibana(f *Framework)

+ func ConsumeCpu(f *Framework, id string, cores int)

+ func ConsumeMemory(f *Framework, id string, gigabytes int)

+ func CoreDump(dir string)

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

+ func FailedContainers(pod *api.Pod) map[string]ContainerFailures

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

+ func GetKubeletPods(c *client.Client, node string) (*api.PodList, error)

+ func HighLatencyRequests(c *client.Client, threshold time.Duration, ignoredResources util.StringSet) (int, error)

+ func LaunchNetTestPodPerNode(f *Framework, nodes *api.NodeList, name, version string) []string

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

+ func NodeSSHHosts(c *client.Client) ([]string, error)

+ func ReserveCpu(f *Framework, id string, millicores int)

+ func ReserveMemory(f *Framework, id string, gigabytes int)

+ func RunRC(config RCConfig) error

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

+ func SSHVerbose(cmd, host, provider string) (string, string, int, error)

+ func ScaleRC(c *client.Client, ns, name string, size uint) error

+ func ServeImageOrFail(f *Framework, test string, image string)

+ func SetTestContext(t TestContextType)

+ func SkipIfProviderIs(unsupportedProviders ...string)

+ func SkipUnlessNodeCountIsAtLeast(minNodeCount int)

+ func SkipUnlessProviderIs(supportedProviders ...string)

+ func Skipf(format string, args ...interface{})

+ func StopConsuming(f *Framework, id string)

+ type CloudConfig struct

+ Cluster string

+ ClusterTag string

+ MasterName string

+ NodeInstanceGroup string

+ NumNodes int

+ ProjectID string

+ Provider cloudprovider.Interface

+ Zone string

+ type ContainerFailures struct

+ type Framework struct

+ BaseName string

+ Client *client.Client

+ Namespace *api.Namespace

+ func InitializeFramework(baseName string, ...) *Framework

+ func NewFramework(baseName string) *Framework

+ func (f *Framework) ReadFileViaContainer(podName, containerName string, path string) (string, error)

+ func (f *Framework) TestContainerOutput(scenarioName string, pod *api.Pod, containerIndex int, expectedOutput []string)

+ func (f *Framework) WaitForAnEndpoint(serviceName string) error

+ func (f *Framework) WaitForPodRunning(podName string) error

+ func (f *Framework) WriteFileViaContainer(podName, containerName string, path string, contents string) error

+ type KubeletMetric struct

+ Latency time.Duration

+ Method string

+ Operation string

+ Quantile float64

+ func HighLatencyKubeletOperations(c *client.Client, threshold time.Duration, nodeName string) ([]KubeletMetric, error)

+ func ParseKubeletMetrics(metricsBlob string) ([]KubeletMetric, error)

+ type KubeletMetricByLatency []KubeletMetric

+ func (a KubeletMetricByLatency) Len() int

+ func (a KubeletMetricByLatency) Less(i, j int) bool

+ func (a KubeletMetricByLatency) Swap(i, j int)

+ type LatencyMetric struct

+ Latency time.Duration

+ Quantile float64

+ Resource string

+ Verb string

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

+ type LatencyMetricByLatency []LatencyMetric

+ func (a LatencyMetricByLatency) Len() int

+ func (a LatencyMetricByLatency) Less(i, j int) bool

+ func (a LatencyMetricByLatency) Swap(i, j int)

+ type PodDiff map[string]*podInfo

+ func Diff(oldPods []*api.Pod, curPods []*api.Pod) PodDiff

+ func (p PodDiff) Print(ignorePhases util.StringSet)

+ type PortsByPodName map[string][]int

+ type PortsByPodUID map[types.UID][]int

+ type RCConfig struct

+ Client *client.Client

+ Command []string

+ CpuLimit int64

+ CreatedPods *[]*api.Pod

+ Env map[string]string

+ Image string

+ Labels map[string]string

+ MaxContainerFailures *int

+ MemLimit int64

+ Name string

+ Namespace string

+ PodStatusFile *os.File

+ PollInterval time.Duration

+ Ports map[string]int

+ Replicas int

+ Timeout time.Duration

+ type State struct

+ Received map[string]int

+ type TestContextType struct

+ CertDir string

+ CloudConfig CloudConfig

+ Host string

+ KubeConfig string

+ KubeContext string

+ KubectlPath string

+ MinStartupPods int

+ OutputDir string

+ PrometheusPushGateway string

+ Provider string

+ RepoRoot string

+ UpgradeTarget string

+ type VolumeTestConfig struct

+ type WebserverTest struct

+ Client *client.Client

+ Labels map[string]string

+ Namespace string

+ ServiceName string

+ TestId string

+ func NewWebserverTest(client *client.Client, namespace string, serviceName string) *WebserverTest

+ func (t *WebserverTest) BuildServiceSpec() *api.Service

+ func (t *WebserverTest) Cleanup() []error

+ func (t *WebserverTest) CreateService(service *api.Service) (*api.Service, error)

+ func (t *WebserverTest) CreateWebserverRC(replicas int) *api.ReplicationController

+ func (t *WebserverTest) DeleteService(serviceName string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL