updateQueueParams updates the breaker queue parameters (not thread safe)
(maxQueueLength, maxConcurrency int)
| 73 | |
| 74 | // updateQueueParams updates the breaker queue parameters (not thread safe) |
| 75 | func (a *apiActivator) updateQueueParams(maxQueueLength, maxConcurrency int) { |
| 76 | a.breaker.UpdateConcurrency(maxConcurrency) |
| 77 | a.breaker.UpdateQueueLength(maxQueueLength) |
| 78 | } |
| 79 | |
| 80 | // inFlight returns the amount of in-flight requests of the breaker |
| 81 | func (a *apiActivator) inFlight() int64 { |
no test coverage detected