Uses of Interface
org.infinispan.manager.ClusterExecutor

Packages that use ClusterExecutor

Package	Description
org.infinispan.manager	Cache manager API.

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<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.