fix-cluster-info

This commit is contained in:
fabriziopandini 2019-10-31 09:48:49 +01:00
parent 004aff411a
commit 5322224ab1
2 changed files with 23 additions and 4 deletions

View File

@ -20,6 +20,7 @@ import (
"fmt"
"k8s.io/kubeadm/kinder/pkg/cluster/status"
"k8s.io/kubeadm/kinder/pkg/constants"
)
// CluterInfo actions prints the summary information about the cluster: list of nodes,
@ -52,12 +53,27 @@ func CluterInfo(c *status.Cluster) error {
// NB. before v1.13 local etcd is listening on localhost only; after v1.13
// local etcd is listening on localhost and on the advertise address; we are
// using localhost to accommodate both the use cases
if err := cp1.Command(
"kubectl", "--kubeconfig=/etc/kubernetes/admin.conf", "exec", "-n=kube-system", fmt.Sprintf("etcd-%s", c.BootstrapControlPlane().Name()),
etcdArgs := []string{
"--kubeconfig=/etc/kubernetes/admin.conf", "exec", "-n=kube-system", fmt.Sprintf("etcd-%s", c.BootstrapControlPlane().Name()),
"--",
"etcdctl", fmt.Sprintf("--endpoints=https://127.0.0.1:2379"),
"--ca-file=/etc/kubernetes/pki/etcd/ca.crt", "--cert-file=/etc/kubernetes/pki/etcd/peer.crt", "--key-file=/etc/kubernetes/pki/etcd/peer.key",
"member", "list",
}
if cp1.MustKubeadmVersion().AtLeast(constants.V1_17) {
etcdArgs = append(etcdArgs,
"--cacert=/etc/kubernetes/pki/etcd/ca.crt", "--cert=/etc/kubernetes/pki/etcd/peer.crt", "--key=/etc/kubernetes/pki/etcd/peer.key",
)
} else {
// before v1.17, etcdctl was using --ca-file, --cert-file, --key-file flags
etcdArgs = append(etcdArgs,
"--ca-file=/etc/kubernetes/pki/etcd/ca.crt", "--cert-file=/etc/kubernetes/pki/etcd/peer.crt", "--key-file=/etc/kubernetes/pki/etcd/peer.key",
)
}
etcdArgs = append(etcdArgs, "member", "list")
if err := cp1.Command(
"kubectl", etcdArgs...,
).RunWithEcho(); err != nil {
return err
}

View File

@ -116,6 +116,9 @@ var (
// V1.16 minor version
V1_16 = K8sVersion.MustParseSemantic("v1.16.0-0")
// V1.17 minor version
V1_17 = K8sVersion.MustParseSemantic("v1.17.0-0")
)
// other constants