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

Store logs from master components from Kubemark runs in GCS

Browse Source
This commit is contained in:
Wojciech Tyczynski 2016-02-16 15:31:08 +01:00
parent 6e2e39864c
commit 3509f80bf9
2 changed files with 32 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
test/e2e/core.go
View File

@ -37,32 +37,12 @@ func CoreDump(dir string) {
}
provider := testContext.Provider
// requires ssh
if !providerIs(providersWithSSH...) {
// requires ssh to master machine
if !providerIs(providersWithMasterSSH...) {
fmt.Printf("Skipping SSH core dump, which is not implemented for %s", provider)
return
}
// Get all nodes' external IPs.
hosts, err := NodeSSHHosts(c)
if err != nil {
fmt.Printf("Error getting node hostnames: %v", err)
return
}
cmds := []command{{"cat /var/log/kube-proxy.log", "kube-proxy"}}
if isUsingSystemdKubelet(provider, hosts...) {
cmds = append(cmds, command{"sudo journalctl --output=cat -u kubelet.service", "kubelet"})
} else {
cmds = append(cmds, []command{
{"cat /var/log/kubelet.log", "kubelet"},
{"cat /var/log/supervisor/supervisord.log", "supervisord"},
{"cat /var/log/dmesg", "dmesg"},
}...)
}
logCore(cmds, hosts, dir, provider)
// I wish there was a better way to get the master IP...
config, err := loadConfig()
if err != nil {
@ -71,7 +51,7 @@ func CoreDump(dir string) {
ix := strings.LastIndex(config.Host, "/")
master := net.JoinHostPort(config.Host[ix+1:], "22")
cmds = []command{
cmds := []command{
{"cat /var/log/kube-apiserver.log", "kube-apiserver"},
{"cat /var/log/kube-scheduler.log", "kube-scheduler"},
{"cat /var/log/kube-controller-manager.log", "kube-controller-manager"},
@ -86,6 +66,32 @@ func CoreDump(dir string) {
}
logCore(cmds, []string{master}, dir, provider)
// requires ssh
if !providerIs(providersWithSSH...) {
fmt.Printf("Skipping SSH core dump for nodes, which is not implemented for %s", provider)
return
}
// Get all nodes' external IPs.
hosts, err := NodeSSHHosts(c)
if err != nil {
fmt.Printf("Error getting node hostnames: %v", err)
return
}
cmds = []command{{"cat /var/log/kube-proxy.log", "kube-proxy"}}
if isUsingSystemdKubelet(provider, hosts...) {
cmds = append(cmds, command{"sudo journalctl --output=cat -u kubelet.service", "kubelet"})
} else {
cmds = append(cmds, []command{
{"cat /var/log/kubelet.log", "kubelet"},
{"cat /var/log/supervisor/supervisord.log", "supervisord"},
{"cat /var/log/dmesg", "dmesg"},
}...)
}
logCore(cmds, hosts, dir, provider)
}
func logCore(cmds []command, hosts []string, dir, provider string) {

3
test/e2e/util.go
View File

@ -314,6 +314,9 @@ func SkipUnlessServerVersionGTE(v semver.Version, c client.ServerVersionInterfac
// providersWithSSH are those providers where each node is accessible with SSH
var providersWithSSH = []string{"gce", "gke", "aws"}
// providersWithMasterSSH are those providers where master node is accessible with SSH
var providersWithMasterSSH = []string{"gce", "gke", "kubemark", "aws"}
type podCondition func(pod *api.Pod) (bool, error)
// podReady returns whether pod has a condition of Ready with a status of true.