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(Callable<T> callable)

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 Details

NoOpCircuitBreaker

public NoOpCircuitBreaker()

Method Details

currentState

public CircuitBreakerState currentState()

run

public <T> T run(Callable<T> callable)

Specified by:

run in interface CircuitBreaker

Overrides:

run in class ExecutorCircuitBreaker

Type Parameters:

T - callable generic type

Parameters:

callable - The callable to be run

Returns:

result of callable