Skip to content
This repository has been archived by the owner on Jan 11, 2023. It is now read-only.

E2E: set stability iterations to 10 by default #3997

Merged
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 6 additions & 8 deletions test/e2e/kubernetes/kubernetes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -70,11 +70,9 @@ var _ = BeforeSuite(func() {
masterSSHPort = "22"
}
masterSSHPrivateKeyFilepath = cfg.GetSSHKeyPath()
// TODO
// If no user-configurable stability iteration value is passed in, run stability tests once
/*if cfg.StabilityIterations == 0 {
cfg.StabilityIterations = 1
}*/
if cfg.StabilityIterations == 0 && !eng.HasWindowsAgents() {
cfg.StabilityIterations = 10
}
})

var _ = Describe("Azure Container Cluster using the Kubernetes Orchestrator", func() {
Expand Down Expand Up @@ -408,15 +406,15 @@ var _ = Describe("Azure Container Cluster using the Kubernetes Orchestrator", fu
}
})

It("should have stable external container networking", func() {
It("should have stable external container networking as we recycle a bunch of pods", func() {
name := fmt.Sprintf("alpine-%s", cfg.Name)
command := fmt.Sprintf("nc -vz 8.8.8.8 53 || nc -vz 8.8.4.4 53")
successes, err := pod.RunCommandMultipleTimes(pod.RunLinuxPod, "alpine", name, command, cfg.StabilityIterations)
Expect(err).NotTo(HaveOccurred())
Expect(successes).To(Equal(cfg.StabilityIterations))
})

It("should have stable internal container networking", func() {
It("should have stable internal container networking as we recycle a bunch of pods", func() {
name := fmt.Sprintf("alpine-%s", cfg.Name)
var command string
if common.IsKubernetesVersionGe(eng.ExpandedDefinition.Properties.OrchestratorProfile.OrchestratorVersion, "1.12.0") {
Expand Down Expand Up @@ -546,7 +544,7 @@ var _ = Describe("Azure Container Cluster using the Kubernetes Orchestrator", fu
Expect(err).NotTo(HaveOccurred())
Expect(ready).To(Equal(true))

By("Ensuring that we have stable external DNS resolution from a container")
By("Ensuring that we have stable external DNS resolution as we recycle a bunch of pods")
name := fmt.Sprintf("alpine-%s", cfg.Name)
command := fmt.Sprintf("nc -vz bbc.co.uk 80 || nc -vz google.com 443 || nc -vz microsoft.com 80")
successes, err := pod.RunCommandMultipleTimes(pod.RunLinuxPod, "alpine", name, command, cfg.StabilityIterations)
Expand Down