Uses of Interface
org.infinispan.manager.ClusterExecutor

Packages that use ClusterExecutor

Package	Description
org.infinispan.manager	Cache manager API.
org.infinispan.manager.impl
org.infinispan.security.actions

Uses of ClusterExecutor in org.infinispan.manager

Methods in org.infinispan.manager that return ClusterExecutor

Modifier and Type	Method	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(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.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.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.

Uses of ClusterExecutor in org.infinispan.manager.impl

Methods in org.infinispan.manager.impl that return ClusterExecutor

Modifier and Type	Method	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)

Uses of ClusterExecutor in org.infinispan.security.actions

Methods in org.infinispan.security.actions that return ClusterExecutor

Modifier and Type	Method	Description
ClusterExecutor	GetClusterExecutorAction.run()