percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-12-11 02:04:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

update get pods command

Browse Source
This commit is contained in:
Aly Kafoury
2020-09-15 19:22:30 +02:00
parent 20bacb32f4
commit e2dab351c6
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/go/pt-k8s-pxc-recovery/recover/recover.go
View File

@@ -58,6 +58,9 @@ func (c *Cluster) getPods() ([]string, error) {
args := []string{
"get",
"pods",
"--no-headers",
"-o",
"custom-columns=:metadata.name",
}
out, err := kubectl.RunCmd(c.Namespace, args...)
if err != nil {
@@ -65,8 +68,7 @@ func (c *Cluster) getPods() ([]string, error) {
}
formatedOutput := strings.Split(out, "\n")
podNames := []string{}
for _, v := range formatedOutput {
podName := strings.Split(v, " ")[0]
for _, podName := range formatedOutput {
if strings.Contains(podName, c.Name) && strings.Contains(podName, "pxc") {
podNames = append(podNames, podName)
}
@@ -230,7 +232,7 @@ func (c *Cluster) FindMostRecentPod() error {
}
match := re.FindStringSubmatch(output)
if len(match) < 2 {
return fmt.Errorf("unable to get seqno")
return fmt.Errorf("Error finding the most recent pod : unable to get seqno")
}
currentSeqNo, err := strconv.Atoi(string(match[1]))
if err != nil {