Method requestWithContext

pkg/proxy/breaker_test.go:371–379

requestWithContext simulates a request in a separate goroutine. The request will either fail immediately (as observable via expectFailure) or block until processSuccessfully is called.

(ctx context.Context)

// request will either fail immediately (as observable via expectFailure)
// or block until processSuccessfully is called.
func (r *requestor) requestWithContext(ctx context.Context) {
	go func() {
		err := r.breaker.Maybe(ctx, func() {
			r.InProgress.Inc()
			<-r.barrierCh
		})
		r.acceptedCh <- err == nil
	}()
}

// expectFailure waits for a request to finish and asserts it to be failed.
func (r *requestor) expectFailure(t *testing.T) {