Package | Description |
---|---|
org.infinispan.manager |
Cache manager package
|
org.infinispan.manager.impl |
Modifier and Type | Method and Description |
---|---|
default ClusterExecutor |
EmbeddedCacheManager.executor()
Providess the cache manager based executor.
|
ClusterExecutor |
DefaultCacheManager.executor() |
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 all current nodes.
|
ClusterExecutor |
ClusterExecutor.timeout(long time,
TimeUnit unit)
The timeout parameter is not adhered to when executing the command locally and is only for remote nodes.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterExecutorImpl
Cluster executor implementation
|
Modifier and Type | Method and Description |
---|---|
ClusterExecutor |
AbstractDelegatingEmbeddedCacheManager.executor() |
ClusterExecutor |
ClusterExecutorImpl.filterTargets(Collection<Address> addresses) |
ClusterExecutor |
ClusterExecutorImpl.filterTargets(Predicate<? super Address> predicate) |
ClusterExecutor |
ClusterExecutorImpl.noFilter() |
ClusterExecutor |
ClusterExecutorImpl.timeout(long time,
TimeUnit unit) |
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.