CircuitBreaker.REQUEST,
                    bytesToPreallocate,
                    "aggregations"
                );
            } else {
                breakerService = AggConstructionContentionBenchmark.this.breakerService;
                preallocated = null;
            }
            breaker = breakerService.getBreaker(CircuitBreaker.REQUEST);

        }

        assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should reopen on failure");
    }

    @Test
    public void testManualReset() {
        // Open the circuit
        circuitBreaker.trip();
        assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN");

        // Manually reset
        circuitBreaker.reset();

            this.consecutiveFailures = consecutiveFailures;
            this.successRate = successRate;
        }

        @Override
        public String toString() {
            return String.format("CircuitBreaker[%s] State=%s, Calls=%d, Success=%.2f%%, Rejected=%d", name, state, totalCalls,
                    successRate * 100, rejectedCalls);
        }
    }

    /**
     * Exception thrown when circuit breaker is open

import org.elasticsearch.action.search.SearchPhaseController;
import org.elasticsearch.action.search.SearchProgressListener;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.common.breaker.CircuitBreaker;
import org.elasticsearch.common.breaker.NoopCircuitBreaker;
import org.elasticsearch.common.lucene.search.TopDocsAndMaxScore;
import org.elasticsearch.index.Index;
import org.elasticsearch.index.shard.ShardId;