Package | Description |
---|---|
org.infinispan.manager |
Cache manager API.
|
Modifier and Type | Method and Description |
---|---|
ClusterExecutor |
ClusterExecutor.allNodeSubmission()
When a command is submitted it will submit this command to all of the available nodes that pass the provided
filter.
|
default ClusterExecutor |
EmbeddedCacheManager.executor()
Providess the cache manager based executor.
|
ClusterExecutor |
DefaultCacheManager.executor() |
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 Address> predicate)
Allows for filtering of address nodes dynamically per invocation.
|
ClusterExecutor |
ClusterExecutor.filterTargets(Collection<Address> addresses)
Allows for filtering of address nodes by only allowing addresses in this collection from being contacted.
|
ClusterExecutor |
ClusterExecutor.filterTargets(Predicate<? super 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.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.