| Modifier and Type | Method and Description |
|---|---|
<T> CommandResult<T> |
CommandExecutor.execute(RemoteCommand<T> command) |
<T> CompletableFuture<CommandResult<T>> |
AsyncCommandExecutor.executeAsync(RemoteCommand<T> command) |
| Modifier and Type | Method and Description |
|---|---|
<T> CommandResult<T> |
BatchingExecutor.execute(RemoteCommand<T> command) |
<T> CompletableFuture<CommandResult<T>> |
AsyncBatchingExecutor.executeAsync(RemoteCommand<T> command) |
| Modifier and Type | Method and Description |
|---|---|
static <I> RemoteCommand<?> |
RemoteCommand.deserialize(DeserializationAdapter<I> adapter,
I input) |
static RemoteCommand<?> |
RemoteCommand.fromJsonCompatibleSnapshot(Map<String,Object> snapshot) |
RemoteCommand<T> |
Request.getCommand() |
default RemoteCommand<?> |
RemoteCommand.toMergedCommand() |
| Modifier and Type | Method and Description |
|---|---|
SerializationHandle<RemoteCommand<?>> |
RemoteCommand.getSerializationHandle() |
| Modifier and Type | Method and Description |
|---|---|
default boolean |
RemoteCommand.canBeMerged(RemoteCommand<?> another) |
default void |
RemoteCommand.mergeInto(RemoteCommand<?> mergedCommand) |
static <O> void |
RemoteCommand.serialize(SerializationAdapter<O> adapter,
O output,
RemoteCommand<?> command,
Version backwardCompatibilityVersion,
Scope scope) |
static Map<String,Object> |
RemoteCommand.toJsonCompatibleSnapshot(RemoteCommand<?> command,
Version backwardCompatibilityVersion,
Scope scope) |
| Constructor and Description |
|---|
Request(RemoteCommand<T> command,
Version backwardCompatibilityVersion,
Long clientSideTime,
ExpirationAfterWriteStrategy expirationStrategy) |
| Modifier and Type | Class and Description |
|---|---|
class |
AddTokensCommand |
class |
CheckConfigurationVersionAndExecuteCommand<T> |
class |
ConsumeAsMuchAsPossibleCommand |
class |
ConsumeIgnoringRateLimitsCommand |
class |
CreateInitialStateAndExecuteCommand<T> |
class |
CreateInitialStateWithVersionOrReplaceConfigurationAndExecuteCommand<T> |
class |
CreateSnapshotCommand |
class |
EstimateAbilityToConsumeCommand |
class |
ForceAddTokensCommand |
class |
GetAvailableTokensCommand |
class |
GetConfigurationCommand |
class |
MultiCommand |
class |
ReplaceConfigurationCommand |
class |
ReserveAndCalculateTimeToSleepCommand |
class |
ResetCommand |
class |
SyncCommand |
class |
TryConsumeAndReturnRemainingTokensCommand |
class |
TryConsumeCommand |
class |
VerboseCommand<T> |
| Modifier and Type | Method and Description |
|---|---|
RemoteCommand<T> |
CheckConfigurationVersionAndExecuteCommand.getTargetCommand() |
RemoteCommand<T> |
CreateInitialStateAndExecuteCommand.getTargetCommand() |
RemoteCommand<T> |
VerboseCommand.getTargetCommand() |
RemoteCommand<T> |
CreateInitialStateWithVersionOrReplaceConfigurationAndExecuteCommand.getTargetCommand() |
RemoteCommand<?> |
CheckConfigurationVersionAndExecuteCommand.toMergedCommand() |
RemoteCommand<?> |
TryConsumeCommand.toMergedCommand() |
RemoteCommand<?> |
VerboseCommand.toMergedCommand() |
| Modifier and Type | Method and Description |
|---|---|
List<RemoteCommand<?>> |
MultiCommand.getCommands() |
SerializationHandle<RemoteCommand<?>> |
CheckConfigurationVersionAndExecuteCommand.getSerializationHandle() |
SerializationHandle<RemoteCommand<?>> |
ConsumeIgnoringRateLimitsCommand.getSerializationHandle() |
SerializationHandle<RemoteCommand<?>> |
VerboseCommand.getSerializationHandle() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CheckConfigurationVersionAndExecuteCommand.canBeMerged(RemoteCommand<?> another) |
boolean |
TryConsumeCommand.canBeMerged(RemoteCommand<?> another) |
boolean |
VerboseCommand.canBeMerged(RemoteCommand<?> another) |
static <T> VerboseCommand<T> |
VerboseCommand.from(RemoteCommand<T> targetCommand) |
void |
CheckConfigurationVersionAndExecuteCommand.mergeInto(RemoteCommand<?> mergedCommand) |
void |
TryConsumeCommand.mergeInto(RemoteCommand<?> mergedCommand) |
void |
VerboseCommand.mergeInto(RemoteCommand<?> mergedCommand) |
| Modifier and Type | Method and Description |
|---|---|
static MultiCommand |
MultiCommand.merge(List<RemoteCommand<?>> commands) |
| Constructor and Description |
|---|
CheckConfigurationVersionAndExecuteCommand(RemoteCommand<T> targetCommand,
long desiredConfigurationVersion) |
CreateInitialStateAndExecuteCommand(BucketConfiguration configuration,
RemoteCommand<T> targetCommand) |
CreateInitialStateWithVersionOrReplaceConfigurationAndExecuteCommand(BucketConfiguration configuration,
RemoteCommand<T> targetCommand,
long desiredConfigurationVersion,
TokensInheritanceStrategy tokensInheritanceStrategy) |
| Constructor and Description |
|---|
MultiCommand(List<RemoteCommand<?>> commands) |
Copyright © 2024. All rights reserved.