com.datastax.oss.driver.api.core.session.throttling

Interface RequestThrottler

All Superinterfaces:

AutoCloseable, Closeable

public interface RequestThrottler
extends Closeable

Limits the number of concurrent requests executed by the driver.

Usage in non-blocking applications: beware that all built-in implementations of this interface use locks for internal coordination, and do not qualify as lock-free, with the obvious exception of PassThroughRequestThrottler. If your application enforces strict lock-freedom, then request throttling should not be enabled.

Method Summary

Modifier and Type	Method and Description
void	register(Throttled request) Registers a new request to be throttled.
void	signalError(Throttled request, Throwable error) Signals that a request has failed.
void	signalSuccess(Throttled request) Signals that a request has succeeded.
void	signalTimeout(Throttled request) Signals that a request has timed out.

Methods inherited from interface java.io.Closeable

close

Method Detail

register

void register(@NonNull
              Throttled request)

Registers a new request to be throttled. The throttler will invoke Throttled.onThrottleReady(boolean) when the request is allowed to proceed.

signalSuccess

void signalSuccess(@NonNull
                   Throttled request)

Signals that a request has succeeded. This indicates to the throttler that another request might be started.

signalError

void signalError(@NonNull
                 Throttled request,
                 @NonNull
                 Throwable error)

Signals that a request has failed. This indicates to the throttler that another request might be started.

signalTimeout

void signalTimeout(@NonNull
                   Throttled request)

Signals that a request has timed out. This indicates to the throttler that this request has stopped (if it was running already), or that it doesn't need to be started in the future.

Note: requests are responsible for handling their own timeout. The throttler does not perform time-based eviction on pending requests.