gfwleak/linxin-coredump-tools
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加创建pod后的超时机制

Browse Source
This commit is contained in:
linxin
2023-05-06 16:57:28 +08:00
parent cd4cc4476c
commit 85b15cfb84
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
coredump-tool/coredump-tool.go
View File

@@ -5,6 +5,7 @@ import (
"coredump-tools/types" "coredump-tools/types"
"crypto/rand" "crypto/rand"
"encoding/json" "encoding/json"
"errors"
"flag" "flag"
"fmt" "fmt"
"math/big" "math/big"
@@ -197,19 +198,22 @@ func debugInpod(conf *rest.Config, clientset *kubernetes.Clientset, config types
// Wait for the Pod to be running and ready // Wait for the Pod to be running and ready
fmt.Printf("Waiting for Pod %q to be ready...\n", podName) fmt.Printf("Waiting for Pod %q to be ready...\n", podName)
for { ready := false
for i := 0; i < 10; i++ {
result, err := clientset.CoreV1().Pods("default").Get(context.Background(), podName, metav1.GetOptions{}) result, err := clientset.CoreV1().Pods("default").Get(context.Background(), podName, metav1.GetOptions{})
if err != nil { if err != nil {
return podName, err return podName, err
} }
status := result.Status status := result.Status
if status.Phase == v1.PodRunning && len(status.ContainerStatuses) > 0 && status.ContainerStatuses[0].Ready { if status.Phase == v1.PodRunning && len(status.ContainerStatuses) > 0 && status.ContainerStatuses[0].Ready {
ready = true
break break
} }
time.Sleep(1 * time.Second) time.Sleep(2 * time.Second)
}
if !ready {
return podName, errors.New("create pod timeout")
} }
fmt.Printf("Pod %q is ready.\n", podName)
// Exec into the container // Exec into the container
// Create exec request // Create exec request
var cmd []string var cmd []string