Uses of Interface
org.infinispan.container.entries.InternalCacheEntry
-
Packages that use InternalCacheEntry Package Description org.infinispan.cache.impl org.infinispan.container Package that contains the interface describing the underlyling API for storage in Infinispanorg.infinispan.container.entries Entries which are stored in data containers.org.infinispan.container.entries.metadata org.infinispan.container.impl Data containers which store cache entries.org.infinispan.container.offheap org.infinispan.context Contexts contain information of a specific invocation on the cache, such as its origins, scope (transactional or non-transactional), as well as invocation-specific flags.org.infinispan.context.impl This package contains different context implementations, selected dynamically based on the type of invocation.org.infinispan.distribution Classes relating to the distributed cache mode.org.infinispan.distribution.impl org.infinispan.eviction Classes related to eviction.org.infinispan.eviction.impl org.infinispan.expiration Cache expiration.org.infinispan.expiration.impl org.infinispan.interceptors.distribution Interceptors dealing with command replication in distributed/replicated mode.org.infinispan.metadata.impl org.infinispan.notifications.cachelistener Cache
-specific notifications and eventing.org.infinispan.persistence Persistence API.org.infinispan.persistence.internal org.infinispan.rest.operations REST Server Operations classes.org.infinispan.scattered.impl org.infinispan.statetransfer Transfer of state to new caches in a cluster.org.infinispan.util General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.org.infinispan.xsite.statetransfer -
-
Uses of InternalCacheEntry in org.infinispan.cache.impl
Methods in org.infinispan.cache.impl with parameters of type InternalCacheEntry Modifier and Type Method Description protected boolean
SimpleCacheImpl. checkExpiration(InternalCacheEntry<K,V> entry, long now)
-
Uses of InternalCacheEntry in org.infinispan.container
Methods in org.infinispan.container that return InternalCacheEntry Modifier and Type Method Description InternalCacheEntry<K,V>
DataContainer. compute(K key, DataContainer.ComputeAction<K,V> action)
Computes the new value for the key.InternalCacheEntry<K,V>
DataContainer.ComputeAction. compute(K key, InternalCacheEntry<K,V> oldEntry, InternalEntryFactory factory)
Computes the new value for the key.InternalCacheEntry<K,V>
DataContainer. get(Object k)
Deprecated.since 10.1 - Please useDataContainer.peek(Object)
instead.InternalCacheEntry<K,V>
DataContainer. peek(Object k)
Retrieves a cache entry in the same way asDataContainer.get(Object)
} except that it does not update or reorder any of the internal constructs.InternalCacheEntry<K,V>
DataContainer. remove(Object k)
Removes an entry from the cacheMethods in org.infinispan.container that return types with arguments of type InternalCacheEntry Modifier and Type Method Description default Set<InternalCacheEntry<K,V>>
DataContainer. entrySet()
Deprecated.Please use iterator method if bulk operations are required.Iterator<InternalCacheEntry<K,V>>
DataContainer. iterator()
Iterator<InternalCacheEntry<K,V>>
DataContainer. iteratorIncludingExpired()
Same asDataContainer.iterator()
except that is also returns expired entries.default Spliterator<InternalCacheEntry<K,V>>
DataContainer. spliterator()
default Spliterator<InternalCacheEntry<K,V>>
DataContainer. spliteratorIncludingExpired()
Same asDataContainer.spliterator()
except that is also returns expired entries.Methods in org.infinispan.container with parameters of type InternalCacheEntry Modifier and Type Method Description InternalCacheEntry<K,V>
DataContainer.ComputeAction. compute(K key, InternalCacheEntry<K,V> oldEntry, InternalEntryFactory factory)
Computes the new value for the key.Method parameters in org.infinispan.container with type arguments of type InternalCacheEntry Modifier and Type Method Description default void
DataContainer. executeTask(KeyFilter<? super K> filter, BiConsumer<? super K,InternalCacheEntry<K,V>> action)
Deprecated.since 9.3 Please use theDataContainer.iterator()
method and apply filtering manuallydefault void
DataContainer. executeTask(KeyValueFilter<? super K,? super V> filter, BiConsumer<? super K,InternalCacheEntry<K,V>> action)
Deprecated.since 9.3 Please use theDataContainer.iterator()
method and apply filtering manually -
Uses of InternalCacheEntry in org.infinispan.container.entries
Classes in org.infinispan.container.entries that implement InternalCacheEntry Modifier and Type Class Description class
AbstractInternalCacheEntry
An abstract internal cache entry that is typically stored in the data containerclass
ImmortalCacheEntry
A cache entry that is immortal/cannot expireclass
L1InternalCacheEntry
AInternalCacheEntry
implementation to store a L1 entry.class
MortalCacheEntry
A cache entry that is mortal.class
TransientCacheEntry
A cache entry that is transient, i.e., it can be considered expired after a period of not being used.class
TransientMortalCacheEntry
A cache entry that is both transient and mortal.Methods in org.infinispan.container.entries that return InternalCacheEntry Modifier and Type Method Description InternalCacheEntry<K,V>
InternalCacheEntry. clone()
InternalCacheEntry
ImmortalCacheValue. toInternalCacheEntry(Object key)
<K> InternalCacheEntry<K,V>
InternalCacheValue. toInternalCacheEntry(K key)
InternalCacheEntry
MortalCacheValue. toInternalCacheEntry(Object key)
InternalCacheEntry
TransientCacheValue. toInternalCacheEntry(Object key)
InternalCacheEntry
TransientMortalCacheValue. toInternalCacheEntry(Object key)
Methods in org.infinispan.container.entries with parameters of type InternalCacheEntry Modifier and Type Method Description long
CacheEntrySizeCalculator. calculateSize(K key, InternalCacheEntry<K,V> ice)
-
Uses of InternalCacheEntry in org.infinispan.container.entries.metadata
Classes in org.infinispan.container.entries.metadata that implement InternalCacheEntry Modifier and Type Class Description class
L1MetadataInternalCacheEntry
AInternalCacheEntry
implementation to store a L1 entry.class
MetadataImmortalCacheEntry
A form ofImmortalCacheEntry
that isMetadataAware
class
MetadataMortalCacheEntry
A cache entry that is mortal and isMetadataAware
class
MetadataTransientCacheEntry
A cache entry that is transient, i.e., it can be considered expired after a period of not being used, andMetadataAware
class
MetadataTransientMortalCacheEntry
A form ofTransientMortalCacheEntry
that isVersioned
Methods in org.infinispan.container.entries.metadata that return InternalCacheEntry Modifier and Type Method Description InternalCacheEntry
MetadataImmortalCacheValue. toInternalCacheEntry(Object key)
InternalCacheEntry
MetadataMortalCacheValue. toInternalCacheEntry(Object key)
InternalCacheEntry
MetadataTransientCacheValue. toInternalCacheEntry(Object key)
InternalCacheEntry
MetadataTransientMortalCacheValue. toInternalCacheEntry(Object key)
-
Uses of InternalCacheEntry in org.infinispan.container.impl
Fields in org.infinispan.container.impl with type parameters of type InternalCacheEntry Modifier and Type Field Description protected PeekableTouchableMap<K,InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. entries
protected com.github.benmanes.caffeine.cache.Cache<K,InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. evictionCache
protected List<Consumer<Iterable<InternalCacheEntry<K,V>>>>
AbstractInternalDataContainer. listeners
protected List<Consumer<Iterable<InternalCacheEntry<K,V>>>>
InternalDataContainerAdapter. listeners
protected AtomicReferenceArray<PeekableTouchableMap<K,InternalCacheEntry<K,V>>>
DefaultSegmentedDataContainer. maps
protected Supplier<PeekableTouchableMap<K,InternalCacheEntry<K,V>>>
DefaultSegmentedDataContainer. mapSupplier
Methods in org.infinispan.container.impl that return InternalCacheEntry Modifier and Type Method Description InternalCacheEntry<K,V>
AbstractDelegatingDataContainer. compute(K key, DataContainer.ComputeAction<K,V> action)
InternalCacheEntry<K,V>
AbstractDelegatingInternalDataContainer. compute(int segment, K key, DataContainer.ComputeAction<K,V> action)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. compute(int segment, K key, DataContainer.ComputeAction<K,V> action)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. compute(K key, DataContainer.ComputeAction<K,V> action)
InternalCacheEntry<K,V>
InternalDataContainer. compute(int segment, K key, DataContainer.ComputeAction<K,V> action)
Same asDataContainer.compute(Object, ComputeAction)
except that the segment of the key can provided to update entries without calculating the segment for the given key.InternalCacheEntry<K,V>
InternalDataContainerAdapter. compute(int segment, K key, DataContainer.ComputeAction<K,V> action)
<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(K key, V value, InternalCacheEntry<?,?> cacheEntry)
Creates a newInternalCacheEntry
instance based on the version and timestamp/lifespan information reflected in theCacheEntry
instance passed in.<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(K key, V value, EntryVersion version, long created, long lifespan, long lastUsed, long maxIdle)
Creates a newInternalCacheEntry
instance<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(K key, V value, Metadata metadata)
Creates a newInternalCacheEntry
instance<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(K key, V value, Metadata metadata, long lifespan, long maxIdle)
Creates a newInternalCacheEntry
instance<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(K key, V value, Metadata metadata, long created, long lifespan, long lastUsed, long maxIdle)
Creates a newInternalCacheEntry
instance<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(CacheEntry<K,V> cacheEntry)
Creates a newInternalCacheEntry
instance based on the key, value, version and timestamp/lifespan information reflected in theCacheEntry
instance passed in.InternalCacheEntry
InternalEntryFactoryImpl. create(Object key, Object value, InternalCacheEntry cacheEntry)
InternalCacheEntry
InternalEntryFactoryImpl. create(Object key, Object value, EntryVersion version, long created, long lifespan, long lastUsed, long maxIdle)
InternalCacheEntry
InternalEntryFactoryImpl. create(Object key, Object value, Metadata metadata)
InternalCacheEntry
InternalEntryFactoryImpl. create(Object key, Object value, Metadata metadata, long lifespan, long maxIdle)
InternalCacheEntry
InternalEntryFactoryImpl. create(Object key, Object value, Metadata metadata, long created, long lifespan, long lastUsed, long maxIdle)
InternalCacheEntry
InternalEntryFactoryImpl. create(CacheEntry cacheEntry)
<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. createL1(K key, V value, Metadata metadata)
Creates a L1 entry.<K,V>
InternalCacheEntryInternalEntryFactoryImpl. createL1(K key, V value, Metadata metadata)
InternalCacheEntry<K,V>
AbstractDelegatingDataContainer. get(Object k)
InternalCacheEntry<K,V>
AbstractDelegatingInternalDataContainer. get(int segment, Object k)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. get(int segment, Object k)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. get(Object k)
InternalCacheEntry<K,V>
InternalDataContainer. get(int segment, Object k)
Deprecated.since 10.1InternalCacheEntry<K,V>
InternalDataContainer. get(Object k)
Deprecated.since 10.1InternalCacheEntry<K,V>
InternalDataContainerAdapter. get(int segment, Object k)
protected InternalCacheEntry<K,V>
AbstractInternalDataContainer.EntryIterator. getNext()
InternalCacheEntry<K,V>
AbstractDelegatingDataContainer. peek(Object k)
InternalCacheEntry<K,V>
AbstractDelegatingInternalDataContainer. peek(int segment, Object k)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. peek(int segment, Object k)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. peek(Object k)
InternalCacheEntry<K,V>
BoundedSegmentedDataContainer. peek(int segment, Object k)
InternalCacheEntry<K,V>
BoundedSegmentedDataContainer. peek(Object k)
InternalCacheEntry<K,V>
InternalDataContainer. peek(int segment, Object k)
Same asDataContainer.peek(Object)
except that the segment of the key can provided to lookup entries without calculating the segment for the given keyInternalCacheEntry<K,V>
InternalDataContainerAdapter. peek(int segment, Object k)
InternalCacheEntry<K,V>
PeekableTouchableContainerMap. peek(Object key)
InternalCacheEntry<K,V>
AbstractDelegatingDataContainer. remove(Object k)
InternalCacheEntry<K,V>
AbstractDelegatingInternalDataContainer. remove(int segment, Object k)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. remove(int segment, Object k)
InternalCacheEntry<K,V>
AbstractInternalDataContainer. remove(Object k)
InternalCacheEntry<K,V>
InternalDataContainer. remove(int segment, Object k)
Same asDataContainer.remove(Object)
except that the segment of the key can provided to remove the entry without calculating the segment for the given key.InternalCacheEntry<K,V>
InternalDataContainerAdapter. remove(int segment, Object k)
<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. update(InternalCacheEntry<K,V> cacheEntry, Metadata metadata)
TODO: Adjust javadoc Updates an existingInternalCacheEntry
with new metadata.<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. update(InternalCacheEntry<K,V> cacheEntry, V value, Metadata metadata)
Similar toInternalEntryFactory.update(org.infinispan.container.entries.InternalCacheEntry, org.infinispan.metadata.Metadata)
but it also updates theInternalCacheEntry
value.InternalCacheEntry
InternalEntryFactoryImpl. update(InternalCacheEntry cacheEntry, Object value, Metadata metadata)
InternalCacheEntry
InternalEntryFactoryImpl. update(InternalCacheEntry ice, Metadata metadata)
Methods in org.infinispan.container.impl that return types with arguments of type InternalCacheEntry Modifier and Type Method Description protected static <K,V>
com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>>AbstractInternalDataContainer. applyListener(com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>> caffeine, org.infinispan.commons.util.EvictionListener<K,InternalCacheEntry<K,V>> listener, com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter)
protected ConcurrentMap<K,InternalCacheEntry<K,V>>
PeekableTouchableContainerMap. delegate()
Set<InternalCacheEntry<K,V>>
AbstractDelegatingDataContainer. entrySet()
Set<InternalCacheEntry<K,V>>
AbstractInternalDataContainer. entrySet()
protected Predicate<InternalCacheEntry<K,V>>
AbstractInternalDataContainer. expiredIterationPredicate(long accessTime)
Returns a predicate that will return false when an entry is expired.protected Spliterator<InternalCacheEntry<K,V>>
AbstractInternalDataContainer. filterExpiredEntries(Spliterator<InternalCacheEntry<K,V>> spliterator)
Returns a new spliterator that will not return entries that have expired.protected abstract PeekableTouchableMap<K,InternalCacheEntry<K,V>>
AbstractInternalDataContainer. getMapForSegment(int segment)
PeekableTouchableMap<K,InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. getMapForSegment(int segment)
protected PeekableTouchableMap<K,InternalCacheEntry<K,V>>
DefaultDataContainer. getMapForSegment(int segment)
PeekableTouchableMap<K,InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. getMapForSegment(int segment)
PeekableTouchableMap<K,InternalCacheEntry<K,V>>
L1SegmentedDataContainer. getMapForSegment(int segment)
Iterator<InternalCacheEntry<K,V>>
AbstractDelegatingDataContainer. iterator()
Iterator<InternalCacheEntry<K,V>>
AbstractDelegatingInternalDataContainer. iterator(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
DefaultDataContainer. iterator()
Iterator<InternalCacheEntry<K,V>>
DefaultDataContainer. iterator(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. iterator()
Iterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. iterator(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
InternalDataContainer. iterator(org.infinispan.commons.util.IntSet segments)
Same asDataContainer.iterator()
except that only entries that map to the provided segments are returned via the iterator.Iterator<InternalCacheEntry<K,V>>
InternalDataContainerAdapter. iterator(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
AbstractDelegatingDataContainer. iteratorIncludingExpired()
Iterator<InternalCacheEntry<K,V>>
AbstractDelegatingInternalDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. iteratorIncludingExpired()
Iterator<InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
DefaultDataContainer. iteratorIncludingExpired()
Iterator<InternalCacheEntry<K,V>>
DefaultDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. iteratorIncludingExpired()
Iterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
InternalDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Same asDataContainer.iteratorIncludingExpired()
except that only entries that map to the provided segments are returned via the iterator.Iterator<InternalCacheEntry<K,V>>
InternalDataContainerAdapter. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<K,V>>
L1SegmentedDataContainer. iteratorIncludingExpired()
Iterator<InternalCacheEntry<K,V>>
L1SegmentedDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
AbstractDelegatingDataContainer. spliterator()
Spliterator<InternalCacheEntry<K,V>>
AbstractDelegatingInternalDataContainer. spliterator(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
DefaultDataContainer. spliterator()
Spliterator<InternalCacheEntry<K,V>>
DefaultDataContainer. spliterator(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. spliterator()
Spliterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. spliterator(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
InternalDataContainer. spliterator(org.infinispan.commons.util.IntSet segments)
Same asDataContainer.spliterator()
except that only entries that map to the provided segments are returned via this spliterator.Spliterator<InternalCacheEntry<K,V>>
InternalDataContainerAdapter. spliterator(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
AbstractDelegatingDataContainer. spliteratorIncludingExpired()
Spliterator<InternalCacheEntry<K,V>>
AbstractDelegatingInternalDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. spliteratorIncludingExpired()
Spliterator<InternalCacheEntry<K,V>>
BoundedSegmentedDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
DefaultDataContainer. spliteratorIncludingExpired()
Spliterator<InternalCacheEntry<K,V>>
DefaultDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. spliteratorIncludingExpired()
Spliterator<InternalCacheEntry<K,V>>
DefaultSegmentedDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
InternalDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Same asDataContainer.spliteratorIncludingExpired()
except that only entries that map to the provided segments are returned via this spliterator.Spliterator<InternalCacheEntry<K,V>>
InternalDataContainerAdapter. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<K,V>>
L1SegmentedDataContainer. spliteratorIncludingExpired()
Spliterator<InternalCacheEntry<K,V>>
L1SegmentedDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Methods in org.infinispan.container.impl with parameters of type InternalCacheEntry Modifier and Type Method Description protected void
AbstractInternalDataContainer. computeEntryRemoved(K key, InternalCacheEntry<K,V> value)
This method is invoked every time an entry is removed inside a compute blockprotected void
BoundedSegmentedDataContainer. computeEntryRemoved(K key, InternalCacheEntry<K,V> value)
protected void
AbstractInternalDataContainer. computeEntryWritten(K key, InternalCacheEntry<K,V> value)
This method is invoked every time an entry is written inside a compute blockprotected void
BoundedSegmentedDataContainer. computeEntryWritten(K key, InternalCacheEntry<K,V> value)
<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. create(K key, V value, InternalCacheEntry<?,?> cacheEntry)
Creates a newInternalCacheEntry
instance based on the version and timestamp/lifespan information reflected in theCacheEntry
instance passed in.InternalCacheEntry
InternalEntryFactoryImpl. create(Object key, Object value, InternalCacheEntry cacheEntry)
static boolean
InternalEntryFactoryImpl. isStoreMetadata(Metadata metadata, InternalCacheEntry ice)
Indicates whether the entire metadata object needs to be stored or not.<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. update(InternalCacheEntry<K,V> cacheEntry, Metadata metadata)
TODO: Adjust javadoc Updates an existingInternalCacheEntry
with new metadata.<K,V>
InternalCacheEntry<K,V>InternalEntryFactory. update(InternalCacheEntry<K,V> cacheEntry, V value, Metadata metadata)
Similar toInternalEntryFactory.update(org.infinispan.container.entries.InternalCacheEntry, org.infinispan.metadata.Metadata)
but it also updates theInternalCacheEntry
value.InternalCacheEntry
InternalEntryFactoryImpl. update(InternalCacheEntry cacheEntry, Object value, Metadata metadata)
InternalCacheEntry
InternalEntryFactoryImpl. update(InternalCacheEntry ice, Metadata metadata)
Method parameters in org.infinispan.container.impl with type arguments of type InternalCacheEntry Modifier and Type Method Description void
AbstractDelegatingInternalDataContainer. addRemovalListener(Consumer<Iterable<InternalCacheEntry<K,V>>> listener)
void
AbstractInternalDataContainer. addRemovalListener(Consumer<Iterable<InternalCacheEntry<K,V>>> listener)
void
InternalDataContainer. addRemovalListener(Consumer<Iterable<InternalCacheEntry<K,V>>> listener)
Adds a listener that is invoked wheneverInternalDataContainer.removeSegments(IntSet)
is invoked providing a way for the listener to see what actual entries were removed from the container.void
InternalDataContainerAdapter. addRemovalListener(Consumer<Iterable<InternalCacheEntry<K,V>>> listener)
protected static <K,V>
com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>>AbstractInternalDataContainer. applyListener(com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>> caffeine, org.infinispan.commons.util.EvictionListener<K,InternalCacheEntry<K,V>> listener, com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter)
protected static <K,V>
com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>>AbstractInternalDataContainer. applyListener(com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>> caffeine, org.infinispan.commons.util.EvictionListener<K,InternalCacheEntry<K,V>> listener, com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter)
protected static <K,V>
com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>>AbstractInternalDataContainer. applyListener(com.github.benmanes.caffeine.cache.Caffeine<K,InternalCacheEntry<K,V>> caffeine, org.infinispan.commons.util.EvictionListener<K,InternalCacheEntry<K,V>> listener, com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter)
void
AbstractDelegatingDataContainer. executeTask(KeyFilter<? super K> filter, BiConsumer<? super K,InternalCacheEntry<K,V>> action)
void
AbstractDelegatingDataContainer. executeTask(KeyValueFilter<? super K,? super V> filter, BiConsumer<? super K,InternalCacheEntry<K,V>> action)
void
DefaultDataContainer. executeTask(KeyFilter<? super K> filter, BiConsumer<? super K,InternalCacheEntry<K,V>> action)
void
DefaultDataContainer. executeTask(KeyValueFilter<? super K,? super V> filter, BiConsumer<? super K,InternalCacheEntry<K,V>> action)
protected Spliterator<InternalCacheEntry<K,V>>
AbstractInternalDataContainer. filterExpiredEntries(Spliterator<InternalCacheEntry<K,V>> spliterator)
Returns a new spliterator that will not return entries that have expired.void
AbstractDelegatingDataContainer. forEach(Consumer<? super InternalCacheEntry<K,V>> action)
void
AbstractDelegatingInternalDataContainer. forEach(org.infinispan.commons.util.IntSet segments, Consumer<? super InternalCacheEntry<K,V>> action)
void
DefaultSegmentedDataContainer. forEach(org.infinispan.commons.util.IntSet segments, Consumer<? super InternalCacheEntry<K,V>> action)
default void
InternalDataContainer. forEach(org.infinispan.commons.util.IntSet segments, Consumer<? super InternalCacheEntry<K,V>> action)
Performs the given action for each element of the container that maps to the given set of segments until all elements have been processed or the action throws an exception.static <K,V>
voidInternalDataContainerAdapter. removeSegmentEntries(DataContainer<K,V> dataContainer, org.infinispan.commons.util.IntSet segments, List<Consumer<Iterable<InternalCacheEntry<K,V>>>> listeners, KeyPartitioner keyPartitioner)
Constructor parameters in org.infinispan.container.impl with type arguments of type InternalCacheEntry Constructor Description BoundedSegmentedDataContainer(int numSegments, long thresholdSize, org.infinispan.commons.util.EntrySizeCalculator<? super K,? super InternalCacheEntry<K,V>> sizeCalculator)
DefaultDataContainer(long thresholdSize, org.infinispan.commons.util.EntrySizeCalculator<? super K,? super InternalCacheEntry<K,V>> sizeCalculator)
Constructor that allows user to provide a size calculator that also handles the cache entry and metadata.DefaultSegmentedDataContainer(Supplier<PeekableTouchableMap<K,InternalCacheEntry<K,V>>> mapSupplier, int numSegments)
EntryIterator(Iterator<InternalCacheEntry<K,V>> it)
L1SegmentedDataContainer(Supplier<PeekableTouchableMap<K,InternalCacheEntry<K,V>>> mapSupplier, int numSegments)
PeekableTouchableContainerMap(ConcurrentMap<K,InternalCacheEntry<K,V>> map)
-
Uses of InternalCacheEntry in org.infinispan.container.offheap
Fields in org.infinispan.container.offheap with type parameters of type InternalCacheEntry Modifier and Type Field Description protected List<Consumer<Iterable<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>>>
BoundedOffHeapDataContainer. listeners
Methods in org.infinispan.container.offheap that return InternalCacheEntry Modifier and Type Method Description InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. compute(int segment, org.infinispan.commons.marshall.WrappedBytes key, DataContainer.ComputeAction<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> action)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. compute(org.infinispan.commons.marshall.WrappedBytes key, DataContainer.ComputeAction<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> action)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. compute(org.infinispan.commons.marshall.WrappedBytes key, BiFunction<? super org.infinispan.commons.marshall.WrappedBytes,? super InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>,? extends InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>> remappingFunction)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
SegmentedBoundedOffHeapDataContainer. compute(int segment, org.infinispan.commons.marshall.WrappedBytes key, DataContainer.ComputeAction<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> action)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
SegmentedBoundedOffHeapDataContainer. compute(org.infinispan.commons.marshall.WrappedBytes key, DataContainer.ComputeAction<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> action)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapEntryFactory. fromMemory(long address)
Create an entry from the off heap pointerInternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapEntryFactoryImpl. fromMemory(long address)
Assumes the address doesn't contain the linked pointer at the beginningInternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. get(int segment, Object k)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. get(Object k)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. get(Object key)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. peek(int segment, Object k)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. peek(Object k)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. peek(Object key)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. put(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> value)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. putIfAbsent(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> value)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. remove(int segment, Object k)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
BoundedOffHeapDataContainer. remove(Object k)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. remove(Object key)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. replace(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> value)
Methods in org.infinispan.container.offheap that return types with arguments of type InternalCacheEntry Modifier and Type Method Description Set<Map.Entry<org.infinispan.commons.marshall.WrappedBytes,InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>>
OffHeapConcurrentMap. entrySet()
protected PeekableTouchableMap<org.infinispan.commons.marshall.WrappedBytes,InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. getMapForSegment(int segment)
Iterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
BoundedOffHeapDataContainer. iterator(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. iterator()
Iterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. iterator(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
BoundedOffHeapDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Iterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. iteratorIncludingExpired()
Iterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. iteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
BoundedOffHeapDataContainer. spliterator(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. spliterator()
Spliterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. spliterator(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
BoundedOffHeapDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Spliterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. spliteratorIncludingExpired()
Spliterator<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapDataContainer. spliteratorIncludingExpired(org.infinispan.commons.util.IntSet segments)
Collection<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>
OffHeapConcurrentMap. values()
Methods in org.infinispan.container.offheap with parameters of type InternalCacheEntry Modifier and Type Method Description InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. put(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> value)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. putIfAbsent(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> value)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. replace(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> value)
boolean
OffHeapConcurrentMap. replace(org.infinispan.commons.marshall.WrappedBytes key, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> oldValue, InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes> newValue)
Method parameters in org.infinispan.container.offheap with type arguments of type InternalCacheEntry Modifier and Type Method Description void
BoundedOffHeapDataContainer. addRemovalListener(Consumer<Iterable<InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>>> listener)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. compute(org.infinispan.commons.marshall.WrappedBytes key, BiFunction<? super org.infinispan.commons.marshall.WrappedBytes,? super InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>,? extends InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>> remappingFunction)
InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>
OffHeapConcurrentMap. compute(org.infinispan.commons.marshall.WrappedBytes key, BiFunction<? super org.infinispan.commons.marshall.WrappedBytes,? super InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>,? extends InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>> remappingFunction)
void
OffHeapConcurrentMap. putAll(Map<? extends org.infinispan.commons.marshall.WrappedBytes,? extends InternalCacheEntry<org.infinispan.commons.marshall.WrappedBytes,org.infinispan.commons.marshall.WrappedBytes>> m)
-
Uses of InternalCacheEntry in org.infinispan.context
Methods in org.infinispan.context with parameters of type InternalCacheEntry Modifier and Type Method Description default boolean
InvocationContext. replaceValue(Object key, InternalCacheEntry cacheEntry)
Deprecated.Since 8.1, useEntryFactory.wrapExternalEntry(InvocationContext, Object, CacheEntry, boolean, boolean)
instead. -
Uses of InternalCacheEntry in org.infinispan.context.impl
Methods in org.infinispan.context.impl with parameters of type InternalCacheEntry Modifier and Type Method Description protected void
AbstractInvocationContext. onEntryValueReplaced(Object key, InternalCacheEntry cacheEntry)
Deprecated.Since 8.1, no longer used. -
Uses of InternalCacheEntry in org.infinispan.distribution
Methods in org.infinispan.distribution with parameters of type InternalCacheEntry Modifier and Type Method Description void
RemoteValueRetrievedListener. remoteValueFound(InternalCacheEntry ice)
Invoked when a remote value is found from a remote source -
Uses of InternalCacheEntry in org.infinispan.distribution.impl
Methods in org.infinispan.distribution.impl with parameters of type InternalCacheEntry Modifier and Type Method Description void
L1ManagerImpl. remoteValueFound(InternalCacheEntry ice)
-
Uses of InternalCacheEntry in org.infinispan.eviction
Methods in org.infinispan.eviction with parameters of type InternalCacheEntry Modifier and Type Method Description void
PassivationManager. passivate(InternalCacheEntry entry)
Method parameters in org.infinispan.eviction with type arguments of type InternalCacheEntry Modifier and Type Method Description void
EvictionManager. onEntryEviction(Map<? extends K,InternalCacheEntry<? extends K,? extends V>> evicted)
Handles notifications of evicted entries -
Uses of InternalCacheEntry in org.infinispan.eviction.impl
Methods in org.infinispan.eviction.impl with parameters of type InternalCacheEntry Modifier and Type Method Description void
PassivationManagerImpl. passivate(InternalCacheEntry entry)
void
PassivationManagerStub. passivate(InternalCacheEntry entry)
Method parameters in org.infinispan.eviction.impl with type arguments of type InternalCacheEntry Modifier and Type Method Description void
EvictionManagerImpl. onEntryEviction(Map<? extends K,InternalCacheEntry<? extends K,? extends V>> evicted)
-
Uses of InternalCacheEntry in org.infinispan.expiration
Methods in org.infinispan.expiration with parameters of type InternalCacheEntry Modifier and Type Method Description void
ExpirationManager. handleInMemoryExpiration(InternalCacheEntry<K,V> entry, long currentTime)
Deprecated.since 9.3 this method is not intended for external use -
Uses of InternalCacheEntry in org.infinispan.expiration.impl
Methods in org.infinispan.expiration.impl with parameters of type InternalCacheEntry Modifier and Type Method Description CompletableFuture<Boolean>
ClusterExpirationManager. entryExpiredInMemory(InternalCacheEntry<K,V> entry, long currentTime, boolean isWrite)
CompletableFuture<Boolean>
ExpirationManagerImpl. entryExpiredInMemory(InternalCacheEntry<K,V> entry, long currentTime, boolean hasLock)
CompletableFuture<Boolean>
InternalExpirationManager. entryExpiredInMemory(InternalCacheEntry<K,V> entry, long currentTime, boolean isWrite)
This should be invoked passing in an entry that is now expired.boolean
ClusterExpirationManager. entryExpiredInMemoryFromIteration(InternalCacheEntry<K,V> entry, long currentTime)
boolean
ExpirationManagerImpl. entryExpiredInMemoryFromIteration(InternalCacheEntry<K,V> entry, long currentTime)
boolean
InternalExpirationManager. entryExpiredInMemoryFromIteration(InternalCacheEntry<K,V> entry, long currentTime)
This method is very similar toInternalExpirationManager.entryExpiredInMemory(InternalCacheEntry, long, boolean)
except that it does the bare minimum when an entry expired to guarantee if the entry is valid or not.void
ExpirationManagerImpl. handleInMemoryExpiration(InternalCacheEntry<K,V> entry, long currentTime)
CompletionStage<Boolean>
ExpirationManagerImpl. handlePossibleExpiration(InternalCacheEntry<K,V> ice, int segment, boolean isWrite)
CompletionStage<Boolean>
InternalExpirationManager. handlePossibleExpiration(InternalCacheEntry<K,V> entry, int segment, boolean isWrite)
Handles processing for an entry that may be expired.protected CompletionStage<Boolean>
ClusterExpirationManager. touchEntryAndReturnIfExpired(InternalCacheEntry ice, int segment)
protected CompletionStage<Boolean>
ExpirationManagerImpl. touchEntryAndReturnIfExpired(InternalCacheEntry entry, int segment)
Response is whether the value should be treated as expired - thus if both local and remote were able to touch then the value is not expired. -
Uses of InternalCacheEntry in org.infinispan.interceptors.distribution
Methods in org.infinispan.interceptors.distribution with parameters of type InternalCacheEntry Modifier and Type Method Description void
L1WriteSynchronizer. runL1UpdateIfPossible(InternalCacheEntry ice)
Attempts to the L1 update and set the value. -
Uses of InternalCacheEntry in org.infinispan.metadata.impl
Constructors in org.infinispan.metadata.impl with parameters of type InternalCacheEntry Constructor Description InternalMetadataImpl(InternalCacheEntry ice)
-
Uses of InternalCacheEntry in org.infinispan.notifications.cachelistener
Method parameters in org.infinispan.notifications.cachelistener with type arguments of type InternalCacheEntry Modifier and Type Method Description void
CacheNotifier. notifyCacheEntriesEvicted(Collection<InternalCacheEntry<? extends K,? extends V>> entries, InvocationContext ctx, FlagAffectedCommand command)
Notifies all registered listeners of aCacheEntriesEvictedEvent
event.void
CacheNotifierImpl. notifyCacheEntriesEvicted(Collection<InternalCacheEntry<? extends K,? extends V>> entries, InvocationContext ctx, FlagAffectedCommand command)
-
Uses of InternalCacheEntry in org.infinispan.persistence
Methods in org.infinispan.persistence that return InternalCacheEntry Modifier and Type Method Description static <K,V>
InternalCacheEntry<K,V>PersistenceUtil. convert(MarshalledEntry<K,V> loaded, InternalEntryFactory factory)
static <K,V>
InternalCacheEntry<K,V>PersistenceUtil. loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, DataContainer.ComputeAction<K,V> action)
Deprecated.since 9.4 This method references PersistenceManager, which isn't a public classstatic <K,V>
InternalCacheEntry<K,V>PersistenceUtil. loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, AtomicReference<Boolean> isLoaded)
Deprecated.since 9.4 This method references PersistenceManager, which isn't a public classstatic <K,V>
InternalCacheEntry<K,V>PersistenceUtil. loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, AtomicReference<Boolean> isLoaded)
Deprecated.since 9.4 This method references PersistenceManager, which isn't a public classMethods in org.infinispan.persistence that return types with arguments of type InternalCacheEntry Modifier and Type Method Description static <K,V>
Set<InternalCacheEntry<K,V>>PersistenceUtil. toEntrySet(AdvancedCacheLoader<K,V> acl, Predicate<? super K> filter, InternalEntryFactory ief)
static <K,V>
Set<InternalCacheEntry>PersistenceUtil. toEntrySet(AdvancedCacheLoader<K,V> acl, KeyFilter<? super K> filter, InternalEntryFactory ief)
Deprecated.Methods in org.infinispan.persistence with parameters of type InternalCacheEntry Modifier and Type Method Description static InternalMetadata
PersistenceUtil. internalMetadata(InternalCacheEntry ice)
-
Uses of InternalCacheEntry in org.infinispan.persistence.internal
Methods in org.infinispan.persistence.internal that return InternalCacheEntry Modifier and Type Method Description static <K,V>
InternalCacheEntry<K,V>PersistenceUtil. convert(MarshalledEntry<K,V> loaded, InternalEntryFactory factory)
static <K,V>
InternalCacheEntry<K,V>PersistenceUtil. loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, DataContainer.ComputeAction<K,V> action)
static <K,V>
InternalCacheEntry<K,V>PersistenceUtil. loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, AtomicReference<Boolean> isLoaded)
static <K,V>
InternalCacheEntry<K,V>PersistenceUtil. loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, PersistenceManager persistenceManager, K key, InvocationContext ctx, org.infinispan.commons.time.TimeService timeService, AtomicReference<Boolean> isLoaded)
-
Uses of InternalCacheEntry in org.infinispan.rest.operations
Methods in org.infinispan.rest.operations with parameters of type InternalCacheEntry Modifier and Type Method Description static <K,V>
DateCacheOperationsHelper. lastModified(InternalCacheEntry<K,V> ice)
-
Uses of InternalCacheEntry in org.infinispan.scattered.impl
Fields in org.infinispan.scattered.impl with type parameters of type InternalCacheEntry Modifier and Type Field Description protected BlockingQueue<InternalCacheEntry>
ScatteredStateConsumerImpl. backupQueue
-
Uses of InternalCacheEntry in org.infinispan.statetransfer
Methods in org.infinispan.statetransfer that return InternalCacheEntry Modifier and Type Method Description static InternalCacheEntry
OutboundTransferTask. defaultMapEntryFromDataContainer(InternalCacheEntry ice, InternalEntryFactory entryFactory)
static InternalCacheEntry
OutboundTransferTask. defaultMapEntryFromStore(MarshalledEntry me, InternalEntryFactory entryFactory)
Methods in org.infinispan.statetransfer that return types with arguments of type InternalCacheEntry Modifier and Type Method Description Collection<InternalCacheEntry>
StateChunk. getCacheEntries()
Methods in org.infinispan.statetransfer with parameters of type InternalCacheEntry Modifier and Type Method Description static InternalCacheEntry
OutboundTransferTask. defaultMapEntryFromDataContainer(InternalCacheEntry ice, InternalEntryFactory entryFactory)
Constructor parameters in org.infinispan.statetransfer with type arguments of type InternalCacheEntry Constructor Description OutboundTransferTask(Address destination, org.infinispan.commons.util.IntSet segments, int segmentCount, int chunkSize, int topologyId, KeyPartitioner keyPartitioner, Consumer<OutboundTransferTask> onCompletion, Consumer<List<StateChunk>> onChunkReplicated, BiFunction<InternalCacheEntry,InternalEntryFactory,InternalCacheEntry> mapEntryFromDataContainer, BiFunction<MarshalledEntry,InternalEntryFactory,InternalCacheEntry> mapEntryFromStore, InternalDataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, CommandsFactory commandsFactory, InternalEntryFactory ef, long timeout, String cacheName, boolean applyState, boolean pushTransfer)
OutboundTransferTask(Address destination, org.infinispan.commons.util.IntSet segments, int segmentCount, int chunkSize, int topologyId, KeyPartitioner keyPartitioner, Consumer<OutboundTransferTask> onCompletion, Consumer<List<StateChunk>> onChunkReplicated, BiFunction<InternalCacheEntry,InternalEntryFactory,InternalCacheEntry> mapEntryFromDataContainer, BiFunction<MarshalledEntry,InternalEntryFactory,InternalCacheEntry> mapEntryFromStore, InternalDataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, CommandsFactory commandsFactory, InternalEntryFactory ef, long timeout, String cacheName, boolean applyState, boolean pushTransfer)
StateChunk(int segmentId, Collection<InternalCacheEntry> cacheEntries, boolean isLastChunk)
-
Uses of InternalCacheEntry in org.infinispan.util
Methods in org.infinispan.util that return InternalCacheEntry Modifier and Type Method Description static <K,V>
InternalCacheEntry<K,V>CoreImmutables. immutableInternalCacheEntry(InternalCacheEntry<K,V> entry)
Wraps aInternalCacheEntry
} with an immutableInternalCacheEntry
}.Methods in org.infinispan.util with parameters of type InternalCacheEntry Modifier and Type Method Description static <K,V>
InternalCacheEntry<K,V>CoreImmutables. immutableInternalCacheEntry(InternalCacheEntry<K,V> entry)
Wraps aInternalCacheEntry
} with an immutableInternalCacheEntry
}. -
Uses of InternalCacheEntry in org.infinispan.xsite.statetransfer
Methods in org.infinispan.xsite.statetransfer with parameters of type InternalCacheEntry Modifier and Type Method Description static XSiteState
XSiteState. fromDataContainer(InternalCacheEntry entry)
-