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

Function newRequestor

pkg/proxy/breaker_test.go:355–361  ·  view source on GitHub ↗
(breaker *Breaker)

Source from the content-addressed store, hash-verified

353}
354
355func newRequestor(breaker *Breaker) *requestor {
356 return &requestor{
357 breaker: breaker,
358 acceptedCh: make(chan bool),
359 barrierCh: make(chan struct{}),
360 }
361}
362
363// request is the same as requestWithContext but with a default context.
364func (r *requestor) request() {

Callers 6

TestBreakerOverloadMixedFunction · 0.85
TestBreakerOverloadFunction · 0.85
TestBreakerQueueingFunction · 0.85
TestBreakerInflightFunction · 0.85
TestBreakerNoOverloadFunction · 0.85
TestBreakerCancelFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected