Package org.infinispan.interceptors.distribution

Interface BaseDistributionInterceptor.ReadManyCommandHelper<C>

All Superinterfaces:

InvocationCallback, InvocationSuccessFunction

All Known Implementing Classes:

BaseDistributionInterceptor.ReadOnlyManyHelper

Enclosing class:

BaseDistributionInterceptor

protected static interface BaseDistributionInterceptor.ReadManyCommandHelper<C>
extends InvocationSuccessFunction

Method Summary

Modifier and Type	Method	Description
void	applyLocalResult(org.infinispan.interceptors.distribution.MergingCompletableFuture allFuture, Object rv)
C	copyForLocal(C command, List<Object> keys)
org.infinispan.commands.functional.ReadOnlyManyCommand	copyForRemote(C command, List<Object> keys, InvocationContext ctx)
CompletionStage<Void>	fetchRequiredKeys(LocalizedCacheTopology cacheTopology, Map<Address,List<Object>> requestedKeys, List<Object> availableKeys, InvocationContext ctx, C command)
Collection<?>	keys(C command)
Object	transformResult(Object[] results)

Methods inherited from interface org.infinispan.interceptors.InvocationSuccessFunction

apply, apply

Method Detail

keys

Collection<?> keys(C command)

copyForLocal

C copyForLocal(C command,
               List<Object> keys)

copyForRemote

org.infinispan.commands.functional.ReadOnlyManyCommand copyForRemote(C command,
                                                                     List<Object> keys,
                                                                     InvocationContext ctx)

applyLocalResult

void applyLocalResult(org.infinispan.interceptors.distribution.MergingCompletableFuture allFuture,
                      Object rv)

transformResult

Object transformResult(Object[] results)

fetchRequiredKeys

CompletionStage<Void> fetchRequiredKeys(LocalizedCacheTopology cacheTopology,
                                        Map<Address,List<Object>> requestedKeys,
                                        List<Object> availableKeys,
                                        InvocationContext ctx,
                                        C command)