ClusterExecutor |
ClusterExecutor.allNodeSubmission() |
When a command is submitted it will submit this command to all of the available nodes that pass the provided
filter.
|
ClusterExecutor |
DefaultCacheManager.executor() |
|
default ClusterExecutor |
EmbeddedCacheManager.executor() |
Providess the cache manager based executor.
|
ClusterExecutor |
ClusterExecutor.filterTargets(Collection<org.infinispan.remoting.transport.Address> addresses) |
Allows for filtering of address nodes by only allowing addresses in this collection from being contacted.
|
ClusterExecutor |
ClusterExecutor.filterTargets(Predicate<? super org.infinispan.remoting.transport.Address> predicate) |
Allows for filtering of address nodes dynamically per invocation.
|
ClusterExecutor |
ClusterExecutor.filterTargets(ClusterExecutionPolicy policy) |
Allows for filtering of address nodes by only allowing addresses that match the given execution policy to be used.
|
ClusterExecutor |
ClusterExecutor.filterTargets(ClusterExecutionPolicy policy,
Predicate<? super org.infinispan.remoting.transport.Address> predicate) |
Allows for filtering of address nodes dynamically per invocation.
|
ClusterExecutor |
ClusterExecutor.noFilter() |
Applies no filtering and will send any invocations to any/all current nodes.
|
ClusterExecutor |
ClusterExecutor.singleNodeSubmission() |
When a command is submitted it will only be submitted to one node of the available nodes, there is no strict
requirements as to which node is chosen and is implementation specific.
|
ClusterExecutor |
ClusterExecutor.singleNodeSubmission(int failOverCount) |
When a command is submitted it will only be submitted to one node of the available nodes, there is no strict
requirements as to which node is chosen and is implementation specific.
|
ClusterExecutor |
ClusterExecutor.timeout(long time,
TimeUnit unit) |
Sets a duration after which a command will timeout.
|