Skip to content

Commit

Permalink
Adjust all tests
Browse files Browse the repository at this point in the history
Signed-off-by: Dimitar Dimitrov <[email protected]>
  • Loading branch information
dimitarvdimitrov committed Sep 20, 2024
1 parent 6e8ff84 commit a299bcd
Showing 1 changed file with 20 additions and 20 deletions.
40 changes: 20 additions & 20 deletions pkg/ingester/circuitbreaker_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -398,7 +398,7 @@ func TestCircuitBreaker_FinishRequest(t *testing.T) {
}
}

func TestIngester_PushToStorage_CircuitBreaker(t *testing.T) {
func TestIngester_IngestStorage_PushToStorage_CircuitBreaker(t *testing.T) {
pushTimeout := 100 * time.Millisecond
tests := map[string]struct {
expectedErrorWhenCircuitBreakerClosed error
Expand Down Expand Up @@ -794,7 +794,7 @@ func TestIngester_Push_CircuitBreaker_DeadlineExceeded(t *testing.T) {
failureThreshold := 2
var initialDelay time.Duration
if initialDelayEnabled {
initialDelay = 200 * time.Millisecond
initialDelay = time.Hour
}
cfg.PushCircuitBreaker = CircuitBreakerConfig{
Enabled: true,
Expand Down Expand Up @@ -906,24 +906,24 @@ func TestIngester_Push_CircuitBreaker_DeadlineExceeded(t *testing.T) {
`
} else {
expectedMetrics = `
# HELP cortex_ingester_circuit_breaker_results_total Results of executing requests via the circuit breaker.
# TYPE cortex_ingester_circuit_breaker_results_total counter
cortex_ingester_circuit_breaker_results_total{request_type="push",result="circuit_breaker_open"} 2
cortex_ingester_circuit_breaker_results_total{request_type="push",result="error"} 2
cortex_ingester_circuit_breaker_results_total{request_type="push",result="success"} 1
# HELP cortex_ingester_circuit_breaker_transitions_total Number of times the circuit breaker has entered a state.
# TYPE cortex_ingester_circuit_breaker_transitions_total counter
cortex_ingester_circuit_breaker_transitions_total{request_type="push",state="closed"} 0
cortex_ingester_circuit_breaker_transitions_total{request_type="push",state="half-open"} 0
cortex_ingester_circuit_breaker_transitions_total{request_type="push",state="open"} 1
# HELP cortex_ingester_circuit_breaker_current_state Boolean set to 1 whenever the circuit breaker is in a state corresponding to the label name.
# TYPE cortex_ingester_circuit_breaker_current_state gauge
cortex_ingester_circuit_breaker_current_state{request_type="push",state="closed"} 0
cortex_ingester_circuit_breaker_current_state{request_type="push",state="half-open"} 0
cortex_ingester_circuit_breaker_current_state{request_type="push",state="open"} 1
# HELP cortex_ingester_circuit_breaker_request_timeouts_total Number of times the circuit breaker recorded a request that reached timeout.
# TYPE cortex_ingester_circuit_breaker_request_timeouts_total counter
cortex_ingester_circuit_breaker_request_timeouts_total{request_type="push"} 2
# HELP cortex_ingester_circuit_breaker_results_total Results of executing requests via the circuit breaker.
# TYPE cortex_ingester_circuit_breaker_results_total counter
cortex_ingester_circuit_breaker_results_total{request_type="push",result="circuit_breaker_open"} 2
cortex_ingester_circuit_breaker_results_total{request_type="push",result="error"} 2
cortex_ingester_circuit_breaker_results_total{request_type="push",result="success"} 1
# HELP cortex_ingester_circuit_breaker_transitions_total Number of times the circuit breaker has entered a state.
# TYPE cortex_ingester_circuit_breaker_transitions_total counter
cortex_ingester_circuit_breaker_transitions_total{request_type="push",state="closed"} 0
cortex_ingester_circuit_breaker_transitions_total{request_type="push",state="half-open"} 0
cortex_ingester_circuit_breaker_transitions_total{request_type="push",state="open"} 1
# HELP cortex_ingester_circuit_breaker_current_state Boolean set to 1 whenever the circuit breaker is in a state corresponding to the label name.
# TYPE cortex_ingester_circuit_breaker_current_state gauge
cortex_ingester_circuit_breaker_current_state{request_type="push",state="closed"} 0
cortex_ingester_circuit_breaker_current_state{request_type="push",state="half-open"} 0
cortex_ingester_circuit_breaker_current_state{request_type="push",state="open"} 1
# HELP cortex_ingester_circuit_breaker_request_timeouts_total Number of times the circuit breaker recorded a request that reached timeout.
# TYPE cortex_ingester_circuit_breaker_request_timeouts_total counter
cortex_ingester_circuit_breaker_request_timeouts_total{request_type="push"} 2
`
}
assert.NoError(t, testutil.GatherAndCompare(registry, strings.NewReader(expectedMetrics), metricNames...))
Expand Down

0 comments on commit a299bcd

Please sign in to comment.