MCPcopy
hub / github.com/cortexlabs/cortex / UpdateQueueLength

Method UpdateQueueLength

pkg/proxy/breaker.go:168–170  ·  view source on GitHub ↗

UpdateQueueLength updates the number of allowed requests in-queue

(size int)

Source from the content-addressed store, hash-verified

166
167// UpdateQueueLength updates the number of allowed requests in-queue
168func (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.
173func (b *Breaker) Capacity() int {

Callers 1

updateQueueParamsMethod · 0.80

Calls 1

CapacityMethod · 0.45

Tested by

no test coverage detected