| 355 | } |
| 356 | |
| 357 | func TestREST_GetLogsStream(t *testing.T) { |
| 358 | reader, err := sharedTestCtx.createAuthenticatedStreamingRequest("GET", "/logs") |
| 359 | if err != nil { |
| 360 | t.Fatalf("Failed to start streaming logs: %v", err) |
| 361 | } |
| 362 | defer reader.Close() |
| 363 | |
| 364 | scanner := bufio.NewScanner(reader) |
| 365 | |
| 366 | for scanner.Scan() { |
| 367 | fmt.Println(scanner.Text()) |
| 368 | } |
| 369 | |
| 370 | if err = scanner.Err(); err != nil { |
| 371 | if errors.Is(err, context.DeadlineExceeded) { |
| 372 | t.Logf("Skipping context deadline exceeded error: %v", err) |
| 373 | return |
| 374 | } |
| 375 | t.Fatalf("Error reading streaming logs: %v", err) |
| 376 | } |
| 377 | } |
| 378 | |
| 379 | func TestREST_GetSystemStats(t *testing.T) { |
| 380 | var systemStats common.SystemStatsResponse |