Package io.openlineage.client.circuitBreaker

Class ExecutorCircuitBreaker

java.lang.Object

io.openlineage.client.circuitBreaker.ExecutorCircuitBreaker

All Implemented Interfaces:

CircuitBreaker

Direct Known Subclasses:

JavaRuntimeCircuitBreaker, NoOpCircuitBreaker, SimpleMemoryCircuitBreaker, StaticCircuitBreaker, TimeoutCircuitBreaker

public abstract class ExecutorCircuitBreaker
extends Object
implements CircuitBreaker

Field Summary

Fields

Modifier and Type	Field	Description
protected Optional<Duration>	timeout

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

CIRCUIT_CHECK_INTERVAL_IN_MILLIS

Constructor Summary

Constructors

Constructor	Description
ExecutorCircuitBreaker(Integer circuitCheckIntervalInMillis)
ExecutorCircuitBreaker(Integer circuitCheckIntervalInMillis, Duration timeout)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getCheckIntervalMillis()
Optional<Duration>	getTimeout()
protected boolean	isPercentageValueValid(Integer value)
<T> T	run(Callable<T> callable)

Methods inherited from class java.lang.Object

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

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

currentState

Field Details

timeout

protected Optional<Duration> timeout

Constructor Details

ExecutorCircuitBreaker

public ExecutorCircuitBreaker(Integer circuitCheckIntervalInMillis)

ExecutorCircuitBreaker

public ExecutorCircuitBreaker(Integer circuitCheckIntervalInMillis,
 Duration timeout)

Method Details

run

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

Specified by:

run in interface CircuitBreaker

Type Parameters:

T - callable generic type

Parameters:

callable - The callable to be run

Returns:

result of callable

getCheckIntervalMillis

public int getCheckIntervalMillis()

Specified by:

getCheckIntervalMillis in interface CircuitBreaker

close

public void close()

Specified by:

close in interface CircuitBreaker

getTimeout

public Optional<Duration> getTimeout()

isPercentageValueValid

protected boolean isPercentageValueValid(Integer value)