Package org.infinispan.context

Interface EntryLookup

All Known Subinterfaces:
InvocationContext, TxInvocationContext<T>
All Known Implementing Classes:
AbstractInvocationContext, AbstractTxInvocationContext, ClearInvocationContext, ImmutableContext, LocalTxInvocationContext, NonTxInvocationContext, RemoteTxInvocationContext, SingleKeyNonTxInvocationContext
public interface EntryLookup
Interface that can look up MVCC wrapped entries.
Since:
4.0
Author:
Manik Surtani (manik@jboss.org)

  • Method Details

    • lookupEntry

      CacheEntry lookupEntry(Object key)
      Retrieves an entry from the collection of looked up entries in the current scope.

      Parameters:
      key - key to look up
      Returns:
      an entry, or null if it cannot be found.

    • getLookedUpEntries

      Map<Object,CacheEntry> getLookedUpEntries()
      Retrieves a map of entries looked up within the current scope.

      Note: The key inside the CacheEntry may be null if the key does not exist in the cache.

      Returns:
      a map of looked up entries.

    • publisher

      <K, V> org.reactivestreams.Publisher<CacheEntry<K,V>> publisher()
      Returns a Publisher that when subscribed to provide all values that have a value in the given context.
      Type Parameters:
      K - key type provided from user
      V - value type provided from user
      Returns:

    • forEachValue

      default void forEachValue(BiConsumer<Object,CacheEntry> action)
      Execute an action for each value in the context.

      Entries that do not have a value (because the key was removed, or it doesn't exist in the cache).

      Since:
      9.3

    • forEachEntry

      default void forEachEntry(BiConsumer<Object,CacheEntry> action)
      Execute an action for each entry in the context. Includes invalid entries, which have a null value and may also report a null key.
      Since:
      9.3

    • lookedUpEntriesCount

      default int lookedUpEntriesCount()
      Returns:
      The number of entries wrapped in the context, including invalid entries.

    • putLookedUpEntry

      void putLookedUpEntry(Object key, CacheEntry e)
      Puts an entry in the registry of looked up entries in the current scope.

      Parameters:
      key - key to store
      e - entry to store

    • removeLookedUpEntry

      void removeLookedUpEntry(Object key)

    • removeLookedUpEntries

      default void removeLookedUpEntries(Collection<?> keys)