UpdateQueueLength updates the number of allowed requests in-queue
(size int)
| 166 | |
| 167 | // UpdateQueueLength updates the number of allowed requests in-queue |
| 168 | func (b *Breaker) UpdateQueueLength(size int) { |
| 169 | b.totalSlots = int64(b.sem.Capacity() + size) |
| 170 | } |
| 171 | |
| 172 | // Capacity returns the number of allowed in-flight requests on this breaker. |
| 173 | func (b *Breaker) Capacity() int { |
no test coverage detected