Package io.openlineage.client.circuitBreaker

Interface CircuitBreaker

All Known Implementing Classes:

ExecutorCircuitBreaker, JavaRuntimeCircuitBreaker, NoOpCircuitBreaker, SimpleMemoryCircuitBreaker, StaticCircuitBreaker, TaskQueueCircuitBreaker

public interface CircuitBreaker

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CIRCUIT_CHECK_INTERVAL_IN_MILLIS

Method Summary

Modifier and Type	Method	Description
void	close()
CircuitBreakerState	currentState()
default int	getCheckIntervalMillis()
<T> T	run(Callable<T> callable)

Field Details

CIRCUIT_CHECK_INTERVAL_IN_MILLIS

static final int CIRCUIT_CHECK_INTERVAL_IN_MILLIS

See Also:

• Constant Field Values

Method Details

currentState

CircuitBreakerState currentState()

run

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

Type Parameters:

T - callable generic type

Parameters:

callable - The callable to be run

Returns:

result of callable

close

void close()

getCheckIntervalMillis

default int getCheckIntervalMillis()