Modifier and Type | Interface and Description |
---|---|
interface |
DataCommand
Commands of this type manipulate data in the cache.
|
interface |
FlagAffectedCommand
Flags modify behavior of command such as whether or not to invoke certain commands remotely, check cache store etc.
|
interface |
GlobalRpcCommand
Commands correspond to specific areas of functionality in the cluster, and can be replicated using the
GlobalInboundInvocationHandler . |
interface |
TopologyAffectedCommand
Some of the commands sent over the wire can only be honored by the receiver if the topology of the cluster at
delivery time is still 'compatible' with the topology in place at send time (eg.
|
interface |
VisitableCommand
A type of command that can accept
Visitor s, such as DDAsyncInterceptor . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFlagAffectedCommand
Base class for those commands that can carry flags.
|
class |
AbstractTopologyAffectedCommand
Base class for commands that carry topology id.
|
Modifier and Type | Method and Description |
---|---|
ReplicableCommand |
RemoteCommandsFactory.fromStream(byte id,
byte type)
Creates an un-initialized command.
|
Modifier and Type | Method and Description |
---|---|
default SingleRpcCommand |
CommandsFactory.buildSingleRpcCommand(ReplicableCommand call)
Deprecated.
since 11.0 use
CommandsFactory.buildSingleRpcCommand(VisitableCommand) instead. |
static int |
SegmentSpecificCommand.extractSegment(ReplicableCommand command,
Object key,
KeyPartitioner keyPartitioner)
Utility to extract the segment from a given command that may be a
SegmentSpecificCommand . |
void |
CommandsFactory.initializeReplicableCommand(ReplicableCommand command,
boolean isRemote)
Deprecated.
since 11.0, please use
CacheRpcCommand.invokeAsync(ComponentRegistry)
or GlobalRpcCommand.invokeAsync(GlobalComponentRegistry) instead.
to access any components required at invocation time. |
void |
CommandsFactoryImpl.initializeReplicableCommand(ReplicableCommand c,
boolean isRemote) |
Modifier and Type | Class and Description |
---|---|
class |
LockControlCommand
LockControlCommand is a command that enables distributed locking across infinispan nodes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractWriteKeyCommand<K,V> |
class |
AbstractWriteManyCommand<K,V> |
class |
ReadOnlyKeyCommand<K,V,R> |
class |
ReadOnlyManyCommand<K,V,R> |
class |
ReadWriteKeyCommand<K,V,R> |
class |
ReadWriteKeyValueCommand<K,V,T,R> |
class |
ReadWriteManyCommand<K,V,R> |
class |
ReadWriteManyEntriesCommand<K,V,T,R> |
class |
TxReadOnlyKeyCommand<K,V,R> |
class |
TxReadOnlyManyCommand<K,V,R> |
class |
WriteOnlyKeyCommand<K,V> |
class |
WriteOnlyKeyValueCommand<K,V,T> |
class |
WriteOnlyManyCommand<K,V> |
class |
WriteOnlyManyEntriesCommand<K,V,T> |
Modifier and Type | Class and Description |
---|---|
class |
IracCleanupKeyCommand
Sends a cleanup request from primary owner to backup owners.
|
class |
IracClearKeysCommand
A clear request that is sent to the remote site by
IracManager . |
class |
IracMetadataRequestCommand
A request for a new
IracMetadata for a giver segment. |
class |
IracPutKeyCommand
A put key request that is sent to the remote site by
IracManager . |
class |
IracRemoveKeyCommand
A remove key request that is sent to the remote site by
IracManager . |
class |
IracRequestStateCommand
Requests the state for a given segments.
|
class |
IracStateResponseCommand
The IRAC state for a given key.
|
class |
IracUpdateKeyCommand
An update request that is sent to the remote site by
IracManager . |
Modifier and Type | Method and Description |
---|---|
ReplicableCommand |
ModuleCommandFactory.fromStream(byte commandId)
Construct and initialize a
ReplicableCommand based on the command id. |
Modifier and Type | Method and Description |
---|---|
Map<Byte,Class<? extends ReplicableCommand>> |
ModuleCommandFactory.getModuleCommands()
Provides a map of command IDs to command types of all the commands handled by the command factory instance.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataCommand |
class |
AbstractLocalCommand
Abstract class
|
class |
EntrySetCommand<K,V>
Command implementation for
Map.entrySet() functionality. |
class |
GetAllCommand
Retrieves multiple entries at once.
|
class |
GetCacheEntryCommand
Used to fetch a full CacheEntry rather than just the value.
|
class |
GetKeyValueCommand
Implements functionality defined by
Map.get(Object) and
Map.containsKey(Object) operations |
class |
KeySetCommand<K,V>
Command implementation for
Map.keySet() functionality. |
class |
SizeCommand
Command to calculate the size of the cache
|
Modifier and Type | Interface and Description |
---|---|
interface |
CacheRpcCommand
The
RpcManager only replicates commands wrapped in a CacheRpcCommand . |
Modifier and Type | Class and Description |
---|---|
class |
BaseClusteredReadCommand |
class |
BaseRpcCommand |
class |
CheckTransactionRpcCommand
|
class |
ClusteredGetAllCommand<K,V>
Issues a remote getAll call.
|
class |
ClusteredGetCommand
Issues a remote get call.
|
class |
GetKeysInGroupCommand
VisitableCommand that fetches the keys belonging to a group. |
class |
RenewBiasCommand |
class |
RevokeBiasCommand
Informs node that it is not allowed to serve reads from the local record anymore.
|
class |
SingleRpcCommand
Aggregates a single command for replication.
|
Modifier and Type | Method and Description |
---|---|
ReplicableCommand |
SingleRpcCommand.getCommand() |
Modifier and Type | Class and Description |
---|---|
class |
CompleteTransactionCommand
Command used by the recovery tooling for forcing transaction completion .
|
class |
GetInDoubtTransactionsCommand
Rpc to obtain all in-doubt prepared transactions stored on remote nodes.
|
class |
GetInDoubtTxInfoCommand
Command used by the recovery tooling for obtaining the list of in-doubt transactions from a node.
|
class |
RecoveryCommand
Deprecated.
since 11.0, class will be removed with no direct replacement. BaseRpcCommand should be extended instead.
|
class |
TxCompletionNotificationCommand
Command for removing recovery related information from the cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
ConflictResolutionStartCommand
Start conflict resolution.
|
class |
ScatteredStateConfirmRevokedCommand
|
class |
ScatteredStateGetKeysCommand
Start transferring keys and remote metadata for the given segments.
|
class |
StateResponseCommand
This command is used by a StateProvider to push cache entries to a StateConsumer.
|
class |
StateTransferCancelCommand
Cancel state transfer.
|
class |
StateTransferGetListenersCommand
Get the registered cluster listeners.
|
class |
StateTransferGetTransactionsCommand
Get transactions for the specified segments.
|
class |
StateTransferStartCommand
Start state transfer.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCacheControlCommand
Abstract class that is the basis for the Cache, Rebalance and Topology commands.
|
class |
CacheAvailabilityUpdateCommand
Change the availability of a cache.
|
class |
CacheJoinCommand
A node is requesting to join the cluster.
|
class |
CacheLeaveCommand
A node is signaling that it wants to leave the cluster.
|
class |
CacheShutdownCommand
Tell members to shutdown cache.
|
class |
CacheShutdownRequestCommand
A member is requesting a cache shutdown.
|
class |
CacheStatusRequestCommand
The coordinator is requesting information about the running caches.
|
class |
RebalancePhaseConfirmCommand
A member is confirming that it has finished a topology change during rebalance.
|
class |
RebalancePolicyUpdateCommand
Enable or Disable rebalancing.
|
class |
RebalanceStartCommand
The coordinator is starting a rebalance operation.
|
class |
RebalanceStatusRequestCommand
Query the rebalancing status.
|
class |
TopologyUpdateCommand
Coordinator to member:
The coordinator is updating the consistent hash.
|
class |
TopologyUpdateStableCommand
Update the stable topology.
|
Modifier and Type | Class and Description |
---|---|
class |
BackupWriteCommand
A write operation sent from the primary owner to the backup owners.
|
class |
MultiEntriesFunctionalBackupWriteCommand
|
class |
MultiKeyFunctionalBackupWriteCommand
|
class |
PutMapBackupWriteCommand
A
BackupWriteCommand implementation for PutMapCommand . |
class |
SingleKeyBackupWriteCommand
A single key
BackupWriteCommand for single key non-functional commands. |
class |
SingleKeyFunctionalBackupWriteCommand
A single key
BackupWriteCommand for single key functional commands. |
Modifier and Type | Interface and Description |
---|---|
interface |
TransactionBoundaryCommand
An transaction boundary command that allows the retrieval of an attached
GlobalTransaction |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTransactionBoundaryCommand
An abstract transaction boundary command that holds a reference to a
GlobalTransaction |
class |
CommitCommand
Command corresponding to the 2nd phase of 2PC.
|
class |
PrepareCommand
Command corresponding to the 1st phase of 2PC.
|
class |
RollbackCommand
Command corresponding to a transaction rollback.
|
class |
VersionedCommitCommand
The same as a
CommitCommand except that version information is also carried by this command, used by
optimistically transactional caches making use of write skew checking when using IsolationLevel.REPEATABLE_READ . |
class |
VersionedPrepareCommand
Same as
PrepareCommand except that the transaction originator makes evident the versions of entries touched
and stored in a transaction context so that accurate write skew checks may be performed by the lock owner(s). |
Modifier and Type | Interface and Description |
---|---|
interface |
DataWriteCommand
Mixes features from DataCommand and WriteCommand
|
interface |
WriteCommand
A command that modifies the cache in some way
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataWriteCommand
Stuff common to WriteCommands
|
class |
BackupAckCommand
A command that represents an acknowledge sent by a backup owner to the originator.
|
class |
BackupMultiKeyAckCommand
A command that represents an acknowledge sent by a backup owner to the originator.
|
class |
ClearCommand |
class |
ComputeCommand |
class |
ComputeIfAbsentCommand |
class |
EvictCommand |
class |
ExceptionAckCommand
A command that represents an exception acknowledge sent by any owner.
|
class |
InvalidateCommand
Removes an entry from memory.
|
class |
InvalidateL1Command
Invalidates an entry in a L1 cache (used with DIST mode)
|
class |
InvalidateVersionsCommand
Must be
VisitableCommand as we want to catch it in persistence handling etc. |
class |
PutKeyValueCommand
Implements functionality defined by
BasicCache.put(Object, Object) |
class |
PutMapCommand
A command writing multiple key/value pairs with the same metadata.
|
class |
RemoveCommand |
class |
RemoveExpiredCommand
Removes an entry that is expired from memory
|
class |
ReplaceCommand |
Modifier and Type | Class and Description |
---|---|
class |
TouchCommand
This command updates a cache entry's last access timestamp.
|
Modifier and Type | Method and Description |
---|---|
protected DistributionInfo |
BaseDistributionInterceptor.retrieveDistributionInfo(LocalizedCacheTopology topology,
ReplicableCommand command,
Object key) |
Modifier and Type | Class and Description |
---|---|
class |
ReplicableManagerFunctionCommand
Replicable Command that runs the given Function passing the
EmbeddedCacheManager as an argument |
class |
ReplicableRunnableCommand
Replicable Command that runs the given Runnable
|
Modifier and Type | Method and Description |
---|---|
ReplicableCommand |
ReplicableCommandExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends ReplicableCommand>> |
ReplicableCommandExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplicableCommandExternalizer.writeCommandHeader(ObjectOutput output,
ReplicableCommand command) |
protected void |
ReplicableCommandExternalizer.writeCommandParameters(ObjectOutput output,
ReplicableCommand command) |
void |
ReplicableCommandExternalizer.writeObject(ObjectOutput output,
ReplicableCommand command) |
Modifier and Type | Class and Description |
---|---|
class |
MultiClusterEventCommand<K,V>
This command is used to send cluster events for multiple listeners on the same node
|
Modifier and Type | Class and Description |
---|---|
class |
CancelPublisherCommand |
class |
InitialPublisherCommand<K,I,R> |
class |
NextPublisherCommand |
Modifier and Type | Class and Description |
---|---|
class |
ReductionPublisherRequestCommand<K>
Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
|
Modifier and Type | Method and Description |
---|---|
void |
GlobalInboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from other node belonging to local site. |
Modifier and Type | Method and Description |
---|---|
<T extends ReplicableCommand> |
ActionState.getCommand() |
Constructor and Description |
---|
ActionState(ReplicableCommand command,
int commandTopologyId,
long timeout) |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
RpcManager.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on a single node and pass the response to a
ResponseCollector . |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on a collection of node and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on a collection of nodes and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
default CompletableFuture<Map<Address,Response>> |
RpcManager.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Deprecated.
|
CompletableFuture<Map<Address,Response>> |
RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
void |
RpcManager.sendTo(Address destination,
ReplicableCommand command,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the destination using the specified DeliverOrder . |
void |
RpcManagerImpl.sendTo(Address destination,
ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
RpcManager.sendToAll(ReplicableCommand command,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the entire cluster. |
void |
RpcManagerImpl.sendToAll(ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
RpcManager.sendToMany(Collection<Address> destinations,
ReplicableCommand command,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the set of destination using the specified DeliverOrder . |
void |
RpcManagerImpl.sendToMany(Collection<Address> destinations,
ReplicableCommand command,
DeliverOrder deliverOrder) |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
RpcManager.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke different commands on a collection of nodes and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a single node and pass the response to a
ResponseCollector . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of node and pass the responses to a
ResponseCollector . |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(Collection<Address> requiredTargets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of nodes and pass the responses to a
ResponseCollector . |
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
|
default Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
Since 9.2, please use
Transport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit) instead. |
CompletableFuture<Map<Address,Response>> |
AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
Transport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
void |
AbstractDelegatingTransport.sendTo(Address destination,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder) |
void |
Transport.sendTo(Address destination,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the destination using the specified DeliverOrder . |
void |
AbstractDelegatingTransport.sendToAll(ReplicableCommand rpcCommand,
DeliverOrder deliverOrder) |
default void |
Transport.sendToAll(ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the entire cluster. |
void |
AbstractDelegatingTransport.sendToMany(Collection<Address> destinations,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder) |
void |
Transport.sendToMany(Collection<Address> destinations,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the set of destination using the specified DeliverOrder . |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit) |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit)
Invoke different commands on a collection of nodes and pass the responses to a
ResponseCollector . |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> responseCollector,
long timeout,
DeliverOrder deliverOrder)
Deprecated.
Introduced in 9.1, but replaced in 9.2 with
Transport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit) . |
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Deprecated.
|
default Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Deprecated.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
|
default Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
Since 9.2, please use
Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead. |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
JGroupsTransport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
CompletableFuture<Map<Address,Response>> |
JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand command,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
void |
JGroupsTransport.sendTo(Address destination,
ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
JGroupsTransport.sendToAll(ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
JGroupsTransport.sendToMany(Collection<Address> targets,
ReplicableCommand command,
DeliverOrder deliverOrder) |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
JGroupsTransport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> commands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
HeartBeatCommand
A hear-beat command used to ping members in
ClusterTopologyManagerImpl.confirmMembersAvailable() . |
Modifier and Type | Method and Description |
---|---|
void |
TopologyManagementHelper.executeOnClusterAsync(Transport transport,
ReplicableCommand command) |
<T> CompletionStage<T> |
TopologyManagementHelper.executeOnClusterSync(Transport transport,
ReplicableCommand command,
int timeout,
ResponseCollector<T> responseCollector) |
CompletionStage<Object> |
TopologyManagementHelper.executeOnCoordinator(Transport transport,
ReplicableCommand command,
long timeoutMillis) |
CompletionStage<Object> |
LocalTopologyManagerImpl.executeOnCoordinatorRetry(ReplicableCommand command,
int viewId,
long endNanos) |
Modifier and Type | Method and Description |
---|---|
Collection<Class<? extends ReplicableCommand>> |
ModuleProperties.moduleCommands()
Deprecated.
|
Collection<Class<? extends ReplicableCommand>> |
ModuleProperties.moduleOnlyReplicableCommands()
Deprecated.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RemoteLockCommand
Simple interface to extract all the keys that may need to be locked.
|
interface |
TransactionalRemoteLockCommand
Simple interface to extract all the keys that may need to be locked for transactional commands.
|
Modifier and Type | Method and Description |
---|---|
void |
Log.errorSendingResponse(long requestId,
org.jgroups.Address origin,
ReplicableCommand command) |
void |
Log_$logger.errorSendingResponse(long requestId,
org.jgroups.Address origin,
ReplicableCommand command) |
void |
Log.exceptionHandlingCommand(ReplicableCommand cmd,
Throwable t) |
void |
Log_$logger.exceptionHandlingCommand(ReplicableCommand cmd,
Throwable t) |
Modifier and Type | Class and Description |
---|---|
class |
SingleXSiteRpcCommand
RPC command to replicate cache operations (such as put, remove, replace, etc.) to the backup site.
|
class |
XSiteReplicateCommand
Abstract class to invoke RPC on the remote site.
|
Modifier and Type | Class and Description |
---|---|
class |
XSiteAmendOfflineStatusCommand
Amend a sites offline status.
|
class |
XSiteBringOnlineCommand
Take a site offline.
|
class |
XSiteOfflineStatusCommand
Get the offline status of a
BackupSender . |
class |
XSiteStateTransferCancelSendCommand
Cancel sending XSite state.
|
class |
XSiteStateTransferClearStatusCommand
Clear XSite state transfer status.
|
class |
XSiteStateTransferFinishReceiveCommand
Finish receiving XSite state.
|
class |
XSiteStateTransferFinishSendCommand
Finish sending XSite state.
|
class |
XSiteStateTransferRestartSendingCommand
Restart sending XSite state.
|
class |
XSiteStateTransferStartReceiveCommand
Start receiving XSite state.
|
class |
XSiteStateTransferStartSendCommand
Start send XSite state.
|
class |
XSiteStateTransferStatusRequestCommand
Get XSite state transfer status.
|
class |
XSiteStatusCommand
Return the status of a
BackupSender . |
class |
XSiteTakeOfflineCommand
Take a site offline.
|
Modifier and Type | Class and Description |
---|---|
class |
XSiteStatePushCommand
Wraps the state to be sent to another site
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.