Package com.codedstreams.otterstreams.sql.runtime

Class InferenceCircuitBreaker

java.lang.Object

com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker

public class InferenceCircuitBreaker
extends Object

Circuit breaker to prevent cascading failures in inference operations.

Since:

1.0.0

Author:

Nestor Martourez Abiangang A.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	InferenceCircuitBreaker.State

Constructor Summary

Constructors

Constructor	Description
InferenceCircuitBreaker(String name, int failureThreshold, long resetTimeoutMs)

Method Summary

Modifier and Type	Method	Description
<T> T	execute(Supplier<T> operation)	Attempts to execute operation through circuit breaker.
int	getFailureCount()
InferenceCircuitBreaker.State	getState()

Methods inherited from class java.lang.Object

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

Constructor Detail

InferenceCircuitBreaker

public InferenceCircuitBreaker(String name,
                               int failureThreshold,
                               long resetTimeoutMs)

Method Detail

execute

public <T> T execute(Supplier<T> operation)
              throws Exception

Attempts to execute operation through circuit breaker.

Throws:

Exception

getState

public InferenceCircuitBreaker.State getState()

getFailureCount

public int getFailureCount()