Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Revert "e2e: kubectl HTTP fix for #15713" #15821

Merged
merged 1 commit into from
Oct 18, 2015
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
52 changes: 17 additions & 35 deletions test/e2e/kubectl.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ import (
"mime/multipart"
"net"
"net/http"
"net/url"
"os"
"os/exec"
"path"
Expand Down Expand Up @@ -198,59 +197,42 @@ var _ = Describe("Kubectl client", func() {
}
})

It("should support exec through an HTTP proxy", func() {
// FIXME(ncdc) remove Skipped once we sort out the kubectl build issues in GCE
It("[Skipped] should support exec through an HTTP proxy", func() {
// Note: We are skipping local since we want to verify an apiserver with HTTPS.
// At this time local only supports plain HTTP.
SkipIfProviderIs("local")
// Fail if the variable isn't set
if testContext.Host == "" {
Failf("--host variable must be set to the full URI to the api server on e2e run.")
}

// Make sure the apiServer is set to what kubectl requires
apiServer := testContext.Host
apiServerUrl, err := url.Parse(apiServer)
if err != nil {
Failf("Unable to parse URL %s. Error=Ts", apiServer, err)
// If there is no api in URL try to add it
if !strings.Contains(apiServer, ":443/api") {
apiServer = apiServer + ":443/api"
}
apiServerUrl.Scheme = "https"
apiServerUrl.Path = "/api"
if !strings.Contains(apiServer, ":443") {
apiServerUrl.Host = apiServerUrl.Host + ":443"
}
apiServer = apiServerUrl.String()

// Get the kube/config
// TODO: Can it be RepoRoot with jenkins e2e?
testWorkspace := os.Getenv("WORKSPACE")
if testWorkspace == "" {
// Not running in jenkins, assume RepoRoot
testWorkspace = testContext.RepoRoot
testWorkspace = testContext.RepoRoot // os.Getenv("HOME")
}

// Build the static kubectl
By("Finding a static kubectl for upload")
testStaticKubectlPath := path.Join(testWorkspace, "platforms/linux/386/kubectl")
_, err = os.Stat(testStaticKubectlPath)
By("Building a static kubectl for upload")
kubectlContainerPath := path.Join(testWorkspace, "/examples/kubectl-container/")
staticKubectlBuild := exec.Command("make", "-C", kubectlContainerPath)
if out, err := staticKubectlBuild.Output(); err != nil {
Failf("Unable to create static kubectl. Error=%s, Output=%s", err, out)
}
// Verify the static kubectl path
testStaticKubectlPath := path.Join(kubectlContainerPath, "kubectl")
_, err := os.Stat(testStaticKubectlPath)
if err != nil {
Logf("No kubectl in %s. Attempting a local build...", testStaticKubectlPath)
// Fall back to trying to build a local static kubectl
kubectlContainerPath := path.Join(testWorkspace, "/examples/kubectl-container/")
if _, err := os.Stat(path.Join(testWorkspace, "hack/build-go.sh")); err != nil {
Failf("Can't build static kubectl due to missing hack/build-go.sh. Error=%s", err)
}
By("Building a static kubectl for upload")
staticKubectlBuild := exec.Command("make", "-C", kubectlContainerPath)
if out, err := staticKubectlBuild.Output(); err != nil {
Failf("Unable to create static kubectl. Error=%s, Output=%q", err, out)
}
// Verify the static kubectl path
testStaticKubectlPath = path.Join(kubectlContainerPath, "kubectl")
_, err := os.Stat(testStaticKubectlPath)
if err != nil {
Failf("static kubectl path could not be found in %s. Error=%s", testStaticKubectlPath, err)
}
Failf("static kubectl path could not be accessed. Error=%s", err)
}
By(fmt.Sprintf("Using the kubectl in %s", testStaticKubectlPath))

// Verify the kubeconfig path
kubeConfigFilePath := testContext.KubeConfig
Expand Down