get timestamp

Signed-off-by: Wenqi Qiu <[email protected]>

test/performance/utils/exec.go

@@ -101,8 +101,7 @@ func PingIP(ctx context.Context, kubeConfig *rest.Config, kc kubernetes.Interfac
 }
 
 func extractNanoseconds(logEntry string) (int, error) {
-	// 1709005058989452190 Status changed from unknown to up after 30217985 seconds
-	re := regexp.MustCompile(`(\d+) Status changed from`)
+	re := regexp.MustCompile(`(\d+)\s+Status changed from (unknown|down)? to up after`)
 	matches := re.FindStringSubmatch(logEntry)
 
 	if len(matches) < 2 {
@@ -135,7 +134,7 @@ func FetchTimestampFromLog(ctx context.Context, kc kubernetes.Interface, namespa
 			return false, fmt.Errorf("error when copying logs for Pod '%s/%s': %w", namespace, podName, err)
 		}
 		klog.InfoS("GetLogs from probe container", "logs", b.String())
-		if strings.Contains(b.String(), "Status changed from unknown to up") {
+		if strings.Contains(b.String(), "Status changed") {
 			changedTimeStamp, err := extractNanoseconds(b.String())
 			if err != nil {
 				return false, err

test/performance/utils/exec_test.go

@@ -6,9 +6,25 @@ import (
 )
 
 func TestExtractSeconds(t *testing.T) {
-	res, err := extractSeconds("Fri Feb 23 06:52:14 UTC 2024 Status changed from unknown to up after 100 seconds")
-	if err != nil {
-		fmt.Println(err)
+	testCases := []struct {
+		name string
+		log  string
+	}{
+		{
+			name: "",
+			log:  "1234567 Status changed from unknown to up after 100 seconds",
+		},
+		{
+			name: "",
+			log:  "12345678 Status changed from down to up after 100 seconds",
+		},
 	}
-	fmt.Println(res)
+	for _, tc := range testCases {
+		res, err := extractNanoseconds(tc.log)
+		if err != nil {
+			fmt.Println(err)
+		}
+		fmt.Println(res)
+	}
+
 }