Package io.openlineage.client.circuitBreaker

Class NoOpCircuitBreaker

java.lang.Object

io.openlineage.client.circuitBreaker.ExecutorCircuitBreaker

io.openlineage.client.circuitBreaker.NoOpCircuitBreaker

All Implemented Interfaces:

CircuitBreaker

public class NoOpCircuitBreaker
extends ExecutorCircuitBreaker

Non-closing circuit breaker which always runs callable.

Field Summary

Fields inherited from class io.openlineage.client.circuitBreaker.ExecutorCircuitBreaker

timeout

Fields inherited from interface io.openlineage.client.circuitBreaker.CircuitBreaker

CIRCUIT_CHECK_INTERVAL_IN_MILLIS

Constructor Summary

Constructors

Constructor	Description
NoOpCircuitBreaker()

Method Summary

Modifier and Type	Method	Description
CircuitBreakerState	currentState()
<T> T	run(java.util.concurrent.Callable<T> callable)	Runs callable and breaks it when circuit breaker is closed

Methods inherited from class io.openlineage.client.circuitBreaker.ExecutorCircuitBreaker

getCheckIntervalMillis, getTimeout, isPercentageValueValid

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NoOpCircuitBreaker

public NoOpCircuitBreaker()

Method Detail

currentState

public CircuitBreakerState currentState()

run

public <T> T run(java.util.concurrent.Callable<T> callable)

Description copied from interface: CircuitBreaker

Runs callable and breaks it when circuit breaker is closed

Specified by:

run in interface CircuitBreaker

Overrides:

run in class ExecutorCircuitBreaker

Returns: