Uses of Interface
org.infinispan.commands.remote.CacheRpcCommand
Packages that use CacheRpcCommand
Package
Description
Commands that operate on the cache, either locally or remotely.
Meta-commands that wrap other commands for remote execution.
Commands that represent transactional lifecycle transitions.
Commands that alter the state of the cache.
Remote communication between cache instances.
Handling of inbound commands on remote nodes.
Abstractions of the different response types allowed during RPC.
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
-
Uses of CacheRpcCommand in org.infinispan.commands
Subinterfaces of CacheRpcCommand in org.infinispan.commandsModifier and TypeInterfaceDescriptioninterfaceCommands of this type manipulate data in the cache.interfaceFlags modify behavior of command such as whether or not to invoke certain commands remotely, check cache store etc.interfaceA type of command that can acceptVisitors, such asDDAsyncInterceptor.Classes in org.infinispan.commands that implement CacheRpcCommandModifier and TypeClassDescriptionclassBase class for those commands that can carry flags.classBase class for commands that carry topology id. -
Uses of CacheRpcCommand in org.infinispan.commands.control
Classes in org.infinispan.commands.control that implement CacheRpcCommandModifier and TypeClassDescriptionclassLockControlCommand is a command that enables distributed locking across infinispan nodes. -
Uses of CacheRpcCommand in org.infinispan.commands.functional
Classes in org.infinispan.commands.functional that implement CacheRpcCommandModifier and TypeClassDescriptionclassclassclassReadOnlyKeyCommand<K,V, R> classReadOnlyManyCommand<K,V, R> final classReadWriteKeyCommand<K,V, R> final classReadWriteKeyValueCommand<K,V, T, R> final classReadWriteManyCommand<K,V, R> final classReadWriteManyEntriesCommand<K,V, T, R> classTxReadOnlyKeyCommand<K,V, R> classTxReadOnlyManyCommand<K,V, R> final classWriteOnlyKeyCommand<K,V> final classWriteOnlyKeyValueCommand<K,V, T> final classWriteOnlyManyCommand<K,V> final classWriteOnlyManyEntriesCommand<K,V, T> -
Uses of CacheRpcCommand in org.infinispan.commands.irac
Classes in org.infinispan.commands.irac that implement CacheRpcCommandModifier and TypeClassDescriptionclassSends a cleanup request from the primary owner to the backup owners.classA request for a newIracMetadatafor a giver segment.classA command received by the primary owner with a list of possible stale keys.classRequests the state for a given segments.classThe IRAC state for a given key.classACacheRpcCommandto clean up tombstones for IRAC algorithm.classACacheRpcCommandto check if one or more tombstones are still valid.classABaseRpcCommandto check tombstones for IRAC algorithm.classResponse for a state request with the tombstones stored in the local node.classIt transfers the current versions stored inIracVersionGeneratorto the other nodes when joins/leaving events occurs. -
Uses of CacheRpcCommand in org.infinispan.commands.read
Classes in org.infinispan.commands.read that implement CacheRpcCommandModifier and TypeClassDescriptionclassclassAbstract classclassEntrySetCommand<K,V> Command implementation forMap.entrySet()functionality.classRetrieves multiple entries at once.final classUsed to fetch a full CacheEntry rather than just the value.classImplements functionality defined byMap.get(Object)andMap.containsKey(Object)operationsclassKeySetCommand<K,V> Command implementation forMap.keySet()functionality.classCommand to calculate the size of the cache -
Uses of CacheRpcCommand in org.infinispan.commands.remote
Classes in org.infinispan.commands.remote that implement CacheRpcCommandModifier and TypeClassDescriptionclassclassclassclassIssues a remote getAll call.classIssues a remote get call. -
Uses of CacheRpcCommand in org.infinispan.commands.remote.recovery
Classes in org.infinispan.commands.remote.recovery that implement CacheRpcCommandModifier and TypeClassDescriptionclassCommand used by the recovery tooling for forcing transaction completion .classRpc to obtain all in-doubt prepared transactions stored on remote nodes.classCommand used by the recovery tooling for obtaining the list of in-doubt transactions from a node.classCommand for removing recovery related information from the cluster. -
Uses of CacheRpcCommand in org.infinispan.commands.statetransfer
Classes in org.infinispan.commands.statetransfer that implement CacheRpcCommandModifier and TypeClassDescriptionclassStart conflict resolution.classThis command is used by a StateProvider to push cache entries to a StateConsumer.classCancel state transfer.classGet the registered cluster listeners.classGet transactions for the specified segments.classStart state transfer. -
Uses of CacheRpcCommand in org.infinispan.commands.triangle
Classes in org.infinispan.commands.triangle that implement CacheRpcCommandModifier and TypeClassDescriptionclassA command that tell a backup owner to ignore a sequence id after the primary failed to send a regular write command.classA write operation sent from the primary owner to the backup owners.classclassclassABackupWriteCommandimplementation forPutMapCommand.classA single keyBackupWriteCommandfor single key non-functional commands.classA single keyBackupWriteCommandfor single key functional commands. -
Uses of CacheRpcCommand in org.infinispan.commands.tx
Subinterfaces of CacheRpcCommand in org.infinispan.commands.txModifier and TypeInterfaceDescriptioninterfaceAn transaction boundary command that allows the retrieval of an attachedGlobalTransactionClasses in org.infinispan.commands.tx that implement CacheRpcCommandModifier and TypeClassDescriptionclassAn abstract transaction boundary command that holds a reference to aGlobalTransactionclassCommand corresponding to the 2nd phase of 2PC.classCommand corresponding to the 1st phase of 2PC.classCommand corresponding to a transaction rollback.classThe same as aCommitCommandexcept that version information is also carried by this command, used by optimistically transactional caches making use of write skew checking when usingIsolationLevel.REPEATABLE_READ.classSame asPrepareCommandexcept 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). -
Uses of CacheRpcCommand in org.infinispan.commands.write
Subinterfaces of CacheRpcCommand in org.infinispan.commands.writeModifier and TypeInterfaceDescriptioninterfaceMixes features from DataCommand and WriteCommandinterfaceA command that modifies the cache in some wayClasses in org.infinispan.commands.write that implement CacheRpcCommandModifier and TypeClassDescriptionclassStuff common to WriteCommandsclassA command that represents an acknowledge sent by a backup owner to the originator.classclassclassclassclassA command that represents an exception acknowledge sent by any owner.classRemoves an entry from memory.classInvalidates an entry in a L1 cache (used with DIST mode)classAWriteCommandused to handle updates from the remote site (for asynchronous cross-site replication).classImplements functionality defined byBasicCache.put(Object, Object)classA command writing multiple key/value pairs with the same metadata.classclassRemoves an entry that is expired from memoryclass -
Uses of CacheRpcCommand in org.infinispan.expiration.impl
Classes in org.infinispan.expiration.impl that implement CacheRpcCommandModifier and TypeClassDescriptionclassThis command updates a cache entry's last access timestamp. -
Uses of CacheRpcCommand in org.infinispan.notifications.cachelistener.cluster
Classes in org.infinispan.notifications.cachelistener.cluster that implement CacheRpcCommandModifier and TypeClassDescriptionclassThis command is used to send cluster events for multiple listeners on the same node -
Uses of CacheRpcCommand in org.infinispan.remoting
Methods in org.infinispan.remoting with parameters of type CacheRpcCommandModifier and TypeMethodDescriptionstatic LocalInvocationLocalInvocation.newInstance(ComponentRegistry componentRegistry, CacheRpcCommand command) static LocalInvocationLocalInvocation.newInstanceFromCache(Cache<?, ?> cache, CacheRpcCommand command) -
Uses of CacheRpcCommand in org.infinispan.remoting.inboundhandler
Fields in org.infinispan.remoting.inboundhandler declared as CacheRpcCommandMethods in org.infinispan.remoting.inboundhandler with parameters of type CacheRpcCommandModifier and TypeMethodDescriptionprotected voidAbstractDelegatingHandler.afterHandle(CacheRpcCommand command, DeliverOrder order, boolean delegated) Invoked after the command is handled.protected booleanAbstractDelegatingHandler.beforeHandle(CacheRpcCommand command, Reply reply, DeliverOrder order) Invoked before the command is handled by the realPerCacheInboundInvocationHandler.voidAbstractDelegatingHandler.handle(CacheRpcCommand command, Reply reply, DeliverOrder order) voidNonTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command, Reply reply, DeliverOrder order) voidPerCacheInboundInvocationHandler.handle(CacheRpcCommand command, Reply reply, DeliverOrder order) Handles theCacheRpcCommandfrom other node.voidTrianglePerCacheInboundInvocationHandler.handle(CacheRpcCommand command, Reply reply, DeliverOrder order) voidTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command, Reply reply, DeliverOrder order) Constructors in org.infinispan.remoting.inboundhandler with parameters of type CacheRpcCommandModifierConstructorDescriptionprotectedBaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler, CacheRpcCommand command, Reply reply, boolean sync) DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler, CacheRpcCommand command, Reply reply, TopologyMode topologyMode, int commandTopologyId, boolean sync) -
Uses of CacheRpcCommand in org.infinispan.remoting.responses
Methods in org.infinispan.remoting.responses with parameters of type CacheRpcCommandModifier and TypeMethodDescriptionDefaultResponseGenerator.getResponse(CacheRpcCommand command, Object rv) ResponseGenerator.getResponse(CacheRpcCommand command, Object returnValue) -
Uses of CacheRpcCommand in org.infinispan.remoting.rpc
Methods in org.infinispan.remoting.rpc with parameters of type CacheRpcCommandModifier and TypeMethodDescription<T> CompletionStage<T> RpcManager.invokeCommand(Collection<Address> targets, CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) Invoke a command on a collection of node and pass the responses to aResponseCollector.<T> CompletionStage<T> RpcManager.invokeCommand(Address target, CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) Invoke a command on a single node and pass the response to aResponseCollector.<T> CompletionStage<T> RpcManagerImpl.invokeCommand(Collection<Address> targets, CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) <T> CompletionStage<T> RpcManagerImpl.invokeCommand(Address target, CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) <T> CompletionStage<T> RpcManager.invokeCommandOnAll(CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector.<T> CompletionStage<T> RpcManagerImpl.invokeCommandOnAll(CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) <T> CompletionStage<T> RpcManager.invokeCommandStaggered(Collection<Address> targets, CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) Invoke a command on a collection of nodes and pass the responses to aResponseCollector.<T> CompletionStage<T> RpcManagerImpl.invokeCommandStaggered(Collection<Address> targets, CacheRpcCommand command, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) voidRpcManager.sendTo(Address destination, CacheRpcCommand command, DeliverOrder deliverOrder) Asynchronously sends theReplicableCommandto the destination using the specifiedDeliverOrder.voidRpcManagerImpl.sendTo(Address destination, CacheRpcCommand command, DeliverOrder deliverOrder) voidRpcManager.sendToAll(CacheRpcCommand command, DeliverOrder deliverOrder) Asynchronously sends theReplicableCommandto the entire cluster.voidRpcManagerImpl.sendToAll(CacheRpcCommand command, DeliverOrder deliverOrder) voidRpcManager.sendToMany(Collection<Address> destinations, CacheRpcCommand command, DeliverOrder deliverOrder) Asynchronously sends theReplicableCommandto the set of destination using the specifiedDeliverOrder.voidRpcManagerImpl.sendToMany(Collection<Address> destinations, CacheRpcCommand command, DeliverOrder deliverOrder) Method parameters in org.infinispan.remoting.rpc with type arguments of type CacheRpcCommandModifier and TypeMethodDescription<T> CompletionStage<T> RpcManager.invokeCommands(Collection<Address> targets, Function<Address, CacheRpcCommand> commandGenerator, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) Invoke different commands on a collection of nodes and pass the responses to aResponseCollector.<T> CompletionStage<T> RpcManagerImpl.invokeCommands(Collection<Address> targets, Function<Address, CacheRpcCommand> commandGenerator, ResponseCollector<Address, T> collector, RpcOptions rpcOptions) -
Uses of CacheRpcCommand in org.infinispan.xsite.commands
Classes in org.infinispan.xsite.commands that implement CacheRpcCommandModifier and TypeClassDescriptionclassAmend a sites offline status.classACacheRpcCommandto check the remote site status and state transfer mode in the local cluster.classACacheRpcCommandthat sets theXSiteStateTransferModecluster-wide.classCancel sending XSite state.classClear XSite state transfer status.classFinish receiving XSite state.classFinish sending XSite state.classRestart sending XSite state.classStart receiving XSite state.classStart send XSite state.classGet XSite state transfer status. -
Uses of CacheRpcCommand in org.infinispan.xsite.statetransfer
Classes in org.infinispan.xsite.statetransfer that implement CacheRpcCommandModifier and TypeClassDescriptionclassWraps the state to be sent to another site