Package | Description |
---|---|
org.infinispan.manager |
Cache manager API.
|
org.infinispan.manager.impl | |
org.infinispan.security.actions |
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.
|
ClusterExecutor |
DefaultCacheManager.executor() |
default ClusterExecutor |
EmbeddedCacheManager.executor()
Providess the cache manager based 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.
|
Modifier and Type | Method and Description |
---|---|
static ClusterExecutor |
ClusterExecutors.allSubmissionExecutor(Predicate<? super Address> predicate,
EmbeddedCacheManager manager,
Transport transport,
long time,
TimeUnit unit,
Executor localExecutor,
ScheduledExecutorService timeoutExecutor) |
ClusterExecutor |
AbstractDelegatingEmbeddedCacheManager.executor() |
static ClusterExecutor |
ClusterExecutors.singleNodeSubmissionExecutor(Predicate<? super Address> predicate,
EmbeddedCacheManager manager,
Transport transport,
long time,
TimeUnit unit,
Executor localExecutor,
ScheduledExecutorService timeoutExecutor,
int failOverCount) |
Modifier and Type | Method and Description |
---|---|
ClusterExecutor |
GetClusterExecutorAction.run() |
Copyright © 2021 JBoss by Red Hat. All rights reserved.