io.github.bucket4j.distributed.remote.commands

Class MultiCommand

java.lang.Object

io.github.bucket4j.distributed.remote.commands.MultiCommand

All Implemented Interfaces:

RemoteCommand<MultiResult>, ComparableByContent<MultiCommand>

public class MultiCommand
extends Object
implements RemoteCommand<MultiResult>, ComparableByContent<MultiCommand>

Field Summary

Fields

Modifier and Type	Field and Description
static int	MERGING_THRESHOLD
static SerializationHandle<MultiCommand>	SERIALIZATION_HANDLE

Constructor Summary

Constructors

Constructor and Description
MultiCommand(List<RemoteCommand<?>> commands)

Method Summary

Modifier and Type	Method and Description
boolean	equalsByContent(MultiCommand other)
long	estimateTokensToConsume()
CommandResult<MultiResult>	execute(MutableBucketEntry mutableEntry, long currentTimeNanos)
List<RemoteCommand<?>>	getCommands()
long	getConsumedTokens(MultiResult multiResult)
int	getMergedCommandsCount()
Version	getRequiredVersion()
SerializationHandle	getSerializationHandle()
boolean	isImmediateSyncRequired(long unsynchronizedTokens, long nanosSinceLastSync)
boolean	isInitializationCommand()
boolean	isMerged()
static MultiCommand	merge(List<RemoteCommand<?>> commands)
List<CommandResult<?>>	unwrap(CommandResult<MultiResult> multiResult)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.github.bucket4j.distributed.remote.RemoteCommand

asVerbose, canBeMerged, deserialize, fromJsonCompatibleSnapshot, mergeInto, serialize, toJsonCompatibleSnapshot, toMergedCommand, unwrapOneResult

Methods inherited from interface io.github.bucket4j.util.ComparableByContent

equals

Field Detail

MERGING_THRESHOLD

public static final int MERGING_THRESHOLD

SERIALIZATION_HANDLE

public static SerializationHandle<MultiCommand> SERIALIZATION_HANDLE

Constructor Detail

MultiCommand

public MultiCommand(List<RemoteCommand<?>> commands)

Method Detail

merge

public static MultiCommand merge(List<RemoteCommand<?>> commands)

unwrap

public List<CommandResult<?>> unwrap(CommandResult<MultiResult> multiResult)

isMerged

public boolean isMerged()

Specified by:

isMerged in interface RemoteCommand<MultiResult>

execute

public CommandResult<MultiResult> execute(MutableBucketEntry mutableEntry,
                                          long currentTimeNanos)

Specified by:

execute in interface RemoteCommand<MultiResult>

isInitializationCommand

public boolean isInitializationCommand()

Specified by:

isInitializationCommand in interface RemoteCommand<MultiResult>

getCommands

public List<RemoteCommand<?>> getCommands()

getSerializationHandle

public SerializationHandle getSerializationHandle()

Specified by:

getSerializationHandle in interface RemoteCommand<MultiResult>

getMergedCommandsCount

public int getMergedCommandsCount()

Specified by:

getMergedCommandsCount in interface RemoteCommand<MultiResult>

equalsByContent

public boolean equalsByContent(MultiCommand other)

Specified by:

equalsByContent in interface ComparableByContent<MultiCommand>

isImmediateSyncRequired

public boolean isImmediateSyncRequired(long unsynchronizedTokens,
                                       long nanosSinceLastSync)

Specified by:

isImmediateSyncRequired in interface RemoteCommand<MultiResult>

estimateTokensToConsume

public long estimateTokensToConsume()

Specified by:

estimateTokensToConsume in interface RemoteCommand<MultiResult>

getConsumedTokens

public long getConsumedTokens(MultiResult multiResult)

Specified by:

getConsumedTokens in interface RemoteCommand<MultiResult>

getRequiredVersion

public Version getRequiredVersion()

Specified by:

getRequiredVersion in interface RemoteCommand<MultiResult>