Class QueryCircuitBreaker
java.lang.Object
org.eclipse.rdf4j.http.client.QueryCircuitBreaker
JVM-global query pressure circuit breaker.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classstatic final classstatic final classstatic interfaceQueryCircuitBreaker.QueryOperation<T, X extends Exception>static final class -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionasCircuitBreakerException(Throwable throwable) voidvoidcheckpoint(QueryCircuitBreakerHandle handle, String operator) voidcomplete(QueryCircuitBreakerHandle handle) <T, X extends Exception>
Texecute(QueryCircuitBreakerHandle handle, RepositoryConnection repositoryConnection, QueryCircuitBreaker.QueryOperation<T, X> operation) static QueryCircuitBreakervoidmarkHeavy(QueryCircuitBreakerHandle handle, String operator) register(QueryCircuitBreakerHandle.Source source, String repositoryId, String queryText) register(QueryCircuitBreakerHandle.Source source, String repositoryId, String queryText, Runnable remoteCancel)
-
Field Details
-
ENABLED_PROPERTY
- See Also:
-
WARN_GC_MS_PROPERTY
- See Also:
-
HIGH_GC_MS_PROPERTY
- See Also:
-
CRITICAL_GC_MS_PROPERTY
- See Also:
-
WARN_FREE_MB_PROPERTY
- See Also:
-
HIGH_FREE_MB_PROPERTY
- See Also:
-
CRITICAL_FREE_MB_PROPERTY
- See Also:
-
WARN_ADMISSION_DELAY_MS_PROPERTY
- See Also:
-
CHECKPOINT_DELAY_MS_PROPERTY
- See Also:
-
CANCEL_COOLDOWN_MS_PROPERTY
- See Also:
-
RETRY_AFTER_SECONDS_PROPERTY
- See Also:
-
-
Constructor Details
-
QueryCircuitBreaker
-
-
Method Details
-
getInstance
-
register
public QueryCircuitBreakerHandle register(QueryCircuitBreakerHandle.Source source, String repositoryId, String queryText) -
register
public QueryCircuitBreakerHandle register(QueryCircuitBreakerHandle.Source source, String repositoryId, String queryText, Runnable remoteCancel) -
execute
public <T, X extends Exception> T execute(QueryCircuitBreakerHandle handle, RepositoryConnection repositoryConnection, QueryCircuitBreaker.QueryOperation<T, X> operation) throws X, QueryInterruptedException- Throws:
XQueryInterruptedException
-
beforeExecution
- Throws:
QueryInterruptedException
-
markHeavy
-
checkpoint
public void checkpoint(QueryCircuitBreakerHandle handle, String operator) throws QueryInterruptedException - Throws:
QueryInterruptedException
-
complete
-
snapshotStatus
-
asCircuitBreakerException
public static QueryCircuitBreaker.CircuitBreakerException asCircuitBreakerException(Throwable throwable)
-