Package org.infinispan.distribution
Interface L1Manager
-
public interface L1Manager
Manages the L1 Cache, in particular recording anyone who is going to cache an a command that a node responds to so that a unicast invalidation can be sent later if needed.- Author:
- Pete Muir
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addRequestor(Object key, org.infinispan.remoting.transport.Address requestor)
Records a request that will be cached in another nodes L1CompletableFuture<?>
flushCache(Collection<Object> key, org.infinispan.remoting.transport.Address origin, boolean assumeOriginKeptEntryInL1)
void
registerL1WriteSynchronizer(Object key, org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)
Registers the given write synchronizer to be notified whenever a remote value is looked up for the given key.void
unregisterL1WriteSynchronizer(Object key, org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)
Unregister the given write synchronizer if present.
-
-
-
Method Detail
-
addRequestor
void addRequestor(Object key, org.infinispan.remoting.transport.Address requestor)
Records a request that will be cached in another nodes L1
-
flushCache
CompletableFuture<?> flushCache(Collection<Object> key, org.infinispan.remoting.transport.Address origin, boolean assumeOriginKeptEntryInL1)
-
registerL1WriteSynchronizer
void registerL1WriteSynchronizer(Object key, org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)
Registers the given write synchronizer to be notified whenever a remote value is looked up for the given key. If the synchronizer is no longer needed to be signaled, the user should unregister it usingunregisterL1WriteSynchronizer(Object, org.infinispan.interceptors.distribution.L1WriteSynchronizer)
- Parameters:
key
- The key that that when looked up will trigger the synchronizersync
- The synchronizer to run the update when the key is looked up
-
unregisterL1WriteSynchronizer
void unregisterL1WriteSynchronizer(Object key, org.infinispan.interceptors.distribution.L1WriteSynchronizer sync)
Unregister the given write synchronizer if present. Note the synchronizer is only unregistered if it matches using instance equality (==) due to possibly concurrent usage of write synchronizers- Parameters:
key
- The key to unregister the given synchronizer for.sync
- The synchronizer to be removed if it is still present.
-
-