Class QueryCircuitBreaker

java.lang.Object

org.eclipse.rdf4j.http.client.QueryCircuitBreaker

public final class QueryCircuitBreaker
extends Object

JVM-global query pressure circuit breaker.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	QueryCircuitBreaker.ActiveQueryStatus
static final class	QueryCircuitBreaker.CircuitBreakerException
static final class	QueryCircuitBreaker.Configuration
static interface	QueryCircuitBreaker.QueryOperation<T, X extends Exception>
static final class	QueryCircuitBreaker.StatusSnapshot

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CANCEL_COOLDOWN_MS_PROPERTY
static final String	CHECKPOINT_DELAY_MS_PROPERTY
static final String	CRITICAL_FREE_MB_PROPERTY
static final String	CRITICAL_GC_MS_PROPERTY
static final String	ENABLED_PROPERTY
static final String	HIGH_FREE_MB_PROPERTY
static final String	HIGH_GC_MS_PROPERTY
static final String	RETRY_AFTER_SECONDS_PROPERTY
static final String	WARN_ADMISSION_DELAY_MS_PROPERTY
static final String	WARN_FREE_MB_PROPERTY
static final String	WARN_GC_MS_PROPERTY

Constructor Summary

Constructors

Constructor	Description
QueryCircuitBreaker(QueryPressureMonitor pressureMonitor)

Method Summary

Modifier and Type	Method	Description
static QueryCircuitBreaker.CircuitBreakerException	asCircuitBreakerException(Throwable throwable)
void	beforeExecution(QueryCircuitBreakerHandle handle)
void	checkpoint(QueryCircuitBreakerHandle handle, String operator)
void	complete(QueryCircuitBreakerHandle handle)
<T, X extends Exception> T	execute(QueryCircuitBreakerHandle handle, RepositoryConnection repositoryConnection, QueryCircuitBreaker.QueryOperation<T,X> operation)
static QueryCircuitBreaker	getInstance()
void	markHeavy(QueryCircuitBreakerHandle handle, String operator)
QueryCircuitBreakerHandle	register(QueryCircuitBreakerHandle.Source source, String repositoryId, String queryText)
QueryCircuitBreakerHandle	register(QueryCircuitBreakerHandle.Source source, String repositoryId, String queryText, Runnable remoteCancel)
QueryCircuitBreaker.StatusSnapshot	snapshotStatus()

Methods inherited from class Object

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

Field Details

ENABLED_PROPERTY

public static final String ENABLED_PROPERTY

See Also:

• Constant Field Values

WARN_GC_MS_PROPERTY

public static final String WARN_GC_MS_PROPERTY

See Also:

• Constant Field Values

HIGH_GC_MS_PROPERTY

public static final String HIGH_GC_MS_PROPERTY

See Also:

• Constant Field Values

CRITICAL_GC_MS_PROPERTY

public static final String CRITICAL_GC_MS_PROPERTY

See Also:

• Constant Field Values

WARN_FREE_MB_PROPERTY

public static final String WARN_FREE_MB_PROPERTY

See Also:

• Constant Field Values

HIGH_FREE_MB_PROPERTY

public static final String HIGH_FREE_MB_PROPERTY

See Also:

• Constant Field Values

CRITICAL_FREE_MB_PROPERTY

public static final String CRITICAL_FREE_MB_PROPERTY

See Also:

• Constant Field Values

WARN_ADMISSION_DELAY_MS_PROPERTY

public static final String WARN_ADMISSION_DELAY_MS_PROPERTY

See Also:

• Constant Field Values

CHECKPOINT_DELAY_MS_PROPERTY

public static final String CHECKPOINT_DELAY_MS_PROPERTY

See Also:

• Constant Field Values

CANCEL_COOLDOWN_MS_PROPERTY

public static final String CANCEL_COOLDOWN_MS_PROPERTY

See Also:

• Constant Field Values

RETRY_AFTER_SECONDS_PROPERTY

public static final String RETRY_AFTER_SECONDS_PROPERTY

See Also:

• Constant Field Values

Constructor Details

QueryCircuitBreaker

public QueryCircuitBreaker(QueryPressureMonitor pressureMonitor)

Method Details

getInstance

public static QueryCircuitBreaker 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:

X

QueryInterruptedException

beforeExecution

public void beforeExecution(QueryCircuitBreakerHandle handle)
                     throws QueryInterruptedException

Throws:

QueryInterruptedException

markHeavy

public void markHeavy(QueryCircuitBreakerHandle handle,
 String operator)

checkpoint

public void checkpoint(QueryCircuitBreakerHandle handle,
 String operator)
                throws QueryInterruptedException

Throws:

QueryInterruptedException

complete

public void complete(QueryCircuitBreakerHandle handle)

snapshotStatus

public QueryCircuitBreaker.StatusSnapshot snapshotStatus()

asCircuitBreakerException

public static QueryCircuitBreaker.CircuitBreakerException asCircuitBreakerException(Throwable throwable)