github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 10:51:29 +00:00
Code Issues Projects Releases Wiki Activity

Revert "Add e2e tests for node log viewer" (#114636)

Browse Source 
This reverts commit ff92963551.
This commit is contained in:
Fabian Fulga 2022-12-21 18:07:27 +02:00 committed by GitHub
parent a6d66d15f6
commit 407bd6a4af
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 79 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

79
test/e2e/node/kubelet.go
View File

@ -19,7 +19,6 @@ package node
import (
"context"
"fmt"
"os/exec"
"path/filepath"
"strings"
"time"
@ -451,82 +450,4 @@ var _ = SIGDescribe("kubelet", func() {
}
})
})
//Test kubectl alpha node-logs <node-name> commands
ginkgo.Describe("kubectl node-logs <node-name> [Feature:add node log viewer]", func() {
var (
numNodes int
nodeNames sets.String
)
ginkgo.BeforeEach(func(ctx context.Context) {
nodes, err := e2enode.GetBoundedReadySchedulableNodes(ctx, c, maxNodesToCheck)
numNodes = len(nodes.Items)
framework.ExpectNoError(err)
nodeNames = sets.NewString()
for i := 0; i < numNodes; i++ {
nodeNames.Insert(nodes.Items[i].Name)
}
})
/*
Test if kubectl node-logs <node-name>
returns something or not!
*/
ginkgo.It("should return the logs ", func(ctx context.Context) {
ginkgo.By("Starting the command")
tk := e2ekubectl.NewTestKubeconfig(framework.TestContext.CertDir, framework.TestContext.Host, framework.TestContext.KubeConfig, framework.TestContext.KubeContext, framework.TestContext.KubectlPath, ns)
for nodeName := range nodeNames {
cmd := tk.KubectlCmd("alpha", "node-logs", nodeName)
runKubectlCommand(cmd, "")
}
})
/*
Test if kubectl node-logs <node-name> --service kubelet
returns something or not!
*/
ginkgo.It("should return the logs for the requested service", func(ctx context.Context) {
ginkgo.By("Starting the command")
tk := e2ekubectl.NewTestKubeconfig(framework.TestContext.CertDir, framework.TestContext.Host, framework.TestContext.KubeConfig, framework.TestContext.KubeContext, framework.TestContext.KubectlPath, ns)
for nodeName := range nodeNames {
cmd := tk.KubectlCmd("alpha", "node-logs", nodeName, "--service", "kubelet")
runKubectlCommand(cmd, "--service")
}
})
/*
Test if kubectl node-logs <node-name> --path pods
returns something or not!
*/
ginkgo.It("should return the logs for the provided path", func(ctx context.Context) {
ginkgo.By("Starting the command")
tk := e2ekubectl.NewTestKubeconfig(framework.TestContext.CertDir, framework.TestContext.Host, framework.TestContext.KubeConfig, framework.TestContext.KubeContext, framework.TestContext.KubectlPath, ns)
for nodeName := range nodeNames {
cmd := tk.KubectlCmd("alpha", "node-logs", nodeName, "--path", "pods")
runKubectlCommand(cmd, "--path")
}
})
})
})
func runKubectlCommand(cmd *exec.Cmd, arg string) {
stdout, stderr, err := framework.StartCmdAndStreamOutput(cmd)
if err != nil {
framework.Failf("Failed to start kubectl command: %v", err)
}
defer stdout.Close()
defer stderr.Close()
defer framework.TryKill(cmd)
buf := make([]byte, 128)
if _, err = stdout.Read(buf); err != nil {
framework.Failf("Expected output from kubectl alpha node-logs %s: %v", arg, err)
}
framework.Logf("output: %s", buf)
}