(nPartitions, nWorkers int, useNewMatching bool)
| 176 | } |
| 177 | |
| 178 | func (s *TaskQueueSuite) testTaskQueueRateLimitName(nPartitions, nWorkers int, useNewMatching bool) string { |
| 179 | ret := fmt.Sprintf("%vPartitions_%vWorkers", nPartitions, nWorkers) |
| 180 | if useNewMatching { |
| 181 | return "NewMatching_" + ret |
| 182 | } |
| 183 | return "OldMatching_" + ret |
| 184 | } |
| 185 | |
| 186 | // configureRateLimitAndLaunchWorkflows sets up the test environment to validate task queue API rate limiting behavior. |
| 187 | // - Applies an API-level RPS override on the activity task queue by calling the updateTaskQueueConfig api. |
no outgoing calls
no test coverage detected