Method QueueLength

pkg/proxy/breaker.go:177–179

()

}

func (b *Breaker) QueueLength() int64 {
	return b.totalSlots - int64(b.sem.Capacity())
}

// newSemaphore creates a semaphore with the desired initial capacity.
func newSemaphore(maxCapacity, initialCapacity int) *semaphore {