| Modifier and Type | Method and Description |
|---|---|
protected abstract <T> CommandResult<T> |
AbstractProxyManager.execute(K key,
Request<T> request) |
<T> CommandResult<T> |
CommandExecutor.execute(RemoteCommand<T> command) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract <T> CompletableFuture<CommandResult<T>> |
AbstractProxyManager.executeAsync(K key,
Request<T> request) |
<T> CompletableFuture<CommandResult<T>> |
AsyncCommandExecutor.executeAsync(RemoteCommand<T> command) |
| Modifier and Type | Method and Description |
|---|---|
<T> CommandResult<T> |
AbstractCompareAndSwapBasedProxyManager.execute(K key,
Request<T> request) |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletableFuture<CommandResult<T>> |
AbstractCompareAndSwapBasedProxyManager.executeAsync(K key,
Request<T> request) |
| Modifier and Type | Method and Description |
|---|---|
<T> CommandResult<T> |
AbstractLockBasedProxyManager.execute(K key,
Request<T> request) |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletableFuture<CommandResult<T>> |
AbstractLockBasedProxyManager.executeAsync(K key,
Request<T> request) |
| Modifier and Type | Method and Description |
|---|---|
<T> CommandResult<T> |
AbstractSelectForUpdateBasedProxyManager.execute(K key,
Request<T> request) |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletableFuture<CommandResult<T>> |
AbstractSelectForUpdateBasedProxyManager.executeAsync(K key,
Request<T> request) |
| Modifier and Type | Method and Description |
|---|---|
<T> CommandResult<T> |
BatchingExecutor.execute(RemoteCommand<T> command) |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletableFuture<CommandResult<T>> |
AsyncBatchingExecutor.executeAsync(RemoteCommand<T> command) |
| Modifier and Type | Field and Description |
|---|---|
static CommandResult<Boolean> |
CommandResult.FALSE |
static CommandResult<Long> |
CommandResult.MAX_VALUE |
static CommandResult<Nothing> |
CommandResult.NOTHING |
static CommandResult<Boolean> |
CommandResult.TRUE |
static CommandResult<Long> |
CommandResult.ZERO |
| Modifier and Type | Field and Description |
|---|---|
static SerializationHandle<CommandResult<?>> |
CommandResult.SERIALIZATION_HANDLE |
| Modifier and Type | Method and Description |
|---|---|
static <R> CommandResult<R> |
CommandResult.bucketNotFound() |
static <R> CommandResult<R> |
CommandResult.configurationNeedToBeReplaced() |
static <R> CommandResult<R> |
CommandResult.empty() |
CommandResult<T> |
RemoteCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
static <R> CommandResult<R> |
CommandResult.success(R data,
int resultTypeId) |
static <R> CommandResult<R> |
CommandResult.success(R data,
SerializationHandle dataSerializer) |
static CommandResult<?> |
CommandResult.unsupportedNamedType(String typeName) |
static CommandResult<?> |
CommandResult.unsupportedType(int typeId) |
static CommandResult<?> |
CommandResult.usageOfObsoleteApiException(int requestedFormatNumber,
int minSupportedFormatNumber) |
static CommandResult<?> |
CommandResult.usageOfUnsupportedApiException(int requestedFormatNumber,
int maxSupportedFormatNumber) |
| Modifier and Type | Method and Description |
|---|---|
List<CommandResult<?>> |
MultiResult.getResults() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CommandResult.equalsByContent(CommandResult other) |
| Constructor and Description |
|---|
MultiResult(List<CommandResult<?>> results) |
| Modifier and Type | Method and Description |
|---|---|
CommandResult<Long> |
ConsumeIgnoringRateLimitsCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<MultiResult> |
MultiCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<T> |
CreateInitialStateAndExecuteCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Boolean> |
TryConsumeCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Nothing> |
ResetCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<RemoteVerboseResult<T>> |
VerboseCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Long> |
ReserveAndCalculateTimeToSleepCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Nothing> |
AddTokensCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Long> |
GetAvailableTokensCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Nothing> |
SyncCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<T> |
CheckConfigurationVersionAndExecuteCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<EstimationProbe> |
EstimateAbilityToConsumeCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<T> |
CreateInitialStateWithVersionOrReplaceConfigurationAndExecuteCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Nothing> |
ReplaceConfigurationCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<RemoteBucketState> |
CreateSnapshotCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<BucketConfiguration> |
GetConfigurationCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Nothing> |
ForceAddTokensCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<Long> |
ConsumeAsMuchAsPossibleCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
CommandResult<ConsumptionProbe> |
TryConsumeAndReturnRemainingTokensCommand.execute(MutableBucketEntry mutableEntry,
long currentTimeNanos) |
| Modifier and Type | Method and Description |
|---|---|
static <T> CommandResult<T> |
InternalSerializationHelper.deserializeResult(byte[] bytes,
Version backwardCompatibilityVersion) |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
InternalSerializationHelper.serializeResult(CommandResult<?> result,
Version backwardCompatibilityVersion) |
Copyright © 2022. All rights reserved.