(appName string, processIndex int, instanceIndex int, shouldRestartFirst bool, expectedLogRateLimit string)
| 386 | } |
| 387 | |
| 388 | func WaitForLogRateLimitToTakeEffect(appName string, processIndex int, instanceIndex int, shouldRestartFirst bool, expectedLogRateLimit string) { |
| 389 | if shouldRestartFirst { |
| 390 | session := CF("restart", appName) |
| 391 | Eventually(session).Should(Exit(0)) |
| 392 | } |
| 393 | |
| 394 | Eventually(func() string { |
| 395 | session := CF("app", appName) |
| 396 | Eventually(session).Should(Exit(0)) |
| 397 | appTable := ParseV3AppProcessTable(session.Out.Contents()) |
| 398 | return appTable.Processes[processIndex].Instances[instanceIndex].LogRate |
| 399 | }).Should(MatchRegexp(fmt.Sprintf(`\d+(\.\d+)?[BKMG]?/s of %s/s`, expectedLogRateLimit))) |
| 400 | } |
no test coverage detected