| Package | Description |
|---|---|
| org.infinispan.cache.impl | |
| org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
| org.infinispan.container |
Package that contains the interface describing the underlyling API for storage in Infinispan
|
| org.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.distribution |
Classes relating to the distributed cache mode.
|
| org.infinispan.distribution.impl | |
| 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.interceptors.impl |
Basic interceptors
|
| org.infinispan.metadata.impl | |
| org.infinispan.persistence |
Persistence API.
|
| org.infinispan.persistence.internal | |
| org.infinispan.persistence.spi |
The Persistence SPI.
|
| org.infinispan.persistence.util | |
| 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 |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
SimpleCacheImpl.checkExpiration(InternalCacheEntry<K,V> entry,
long now) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> IracPutKeyCommand |
CommandsFactory.buildIracPutKeyCommand(InternalCacheEntry<K,V> entry) |
<K,V> IracPutKeyCommand |
CommandsFactoryImpl.buildIracPutKeyCommand(InternalCacheEntry<K,V> entry) |
| Modifier and Type | Method and 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 use
DataContainer.peek(Object) instead. |
InternalCacheEntry<K,V> |
DataContainer.peek(Object k)
Retrieves a cache entry in the same way as
DataContainer.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 cache
The
key must be activate by invoking ActivationManager.activateAsync(Object, int) |
| Modifier and Type | Method and Description |
|---|---|
Iterator<InternalCacheEntry<K,V>> |
DataContainer.iterator() |
Iterator<InternalCacheEntry<K,V>> |
DataContainer.iteratorIncludingExpired()
Same as
DataContainer.iterator() except that is also returns expired entries. |
default Spliterator<InternalCacheEntry<K,V>> |
DataContainer.spliterator() |
default Spliterator<InternalCacheEntry<K,V>> |
DataContainer.spliteratorIncludingExpired()
Same as
DataContainer.spliterator() except that is also returns expired entries. |
| Modifier and Type | Method and Description |
|---|---|
InternalCacheEntry<K,V> |
DataContainer.ComputeAction.compute(K key,
InternalCacheEntry<K,V> oldEntry,
InternalEntryFactory factory)
Computes the new value for the key.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractInternalCacheEntry
An abstract internal cache entry that is typically stored in the data container
|
class |
ImmortalCacheEntry
A cache entry that is immortal/cannot expire
|
class |
L1InternalCacheEntry
A
InternalCacheEntry 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.
|
| Modifier and Type | Method and Description |
|---|---|
InternalCacheEntry<K,V> |
InternalCacheEntry.clone() |
<K> InternalCacheEntry<K,V> |
InternalCacheValue.toInternalCacheEntry(K key) |
InternalCacheEntry<?,?> |
ImmortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry<?,?> |
MortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry<?,?> |
TransientCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry<?,?> |
TransientMortalCacheValue.toInternalCacheEntry(Object key) |
| Modifier and Type | Method and Description |
|---|---|
long |
CacheEntrySizeCalculator.calculateSize(K key,
InternalCacheEntry<K,V> ice) |
| Modifier and Type | Class and Description |
|---|---|
class |
L1MetadataInternalCacheEntry
A
InternalCacheEntry implementation to store a L1 entry. |
class |
MetadataImmortalCacheEntry
A form of
ImmortalCacheEntry that is MetadataAware |
class |
MetadataMortalCacheEntry
A cache entry that is mortal and is
MetadataAware |
class |
MetadataTransientCacheEntry
A cache entry that is transient, i.e., it can be considered expired after a period of not being used, and
MetadataAware |
class |
MetadataTransientMortalCacheEntry
A form of
TransientMortalCacheEntry that stores Metadata |
| Modifier and Type | Method and Description |
|---|---|
InternalCacheEntry<?,?> |
MetadataImmortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry<?,?> |
MetadataMortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry<?,?> |
MetadataTransientCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry<?,?> |
MetadataTransientMortalCacheValue.toInternalCacheEntry(Object key) |
| Modifier and Type | Field and Description |
|---|---|
protected com.github.benmanes.caffeine.cache.Cache<K,InternalCacheEntry<K,V>> |
BoundedSegmentedDataContainer.evictionCache |
protected List<Consumer<Iterable<InternalCacheEntry<K,V>>>> |
AbstractInternalDataContainer.listeners |
protected io.reactivex.rxjava3.functions.Predicate<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.notExpiredPredicate |
| Modifier and Type | Method and Description |
|---|---|
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> |
InternalDataContainer.compute(int segment,
K key,
DataContainer.ComputeAction<K,V> action)
Same as
DataContainer.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> |
AbstractDelegatingInternalDataContainer.compute(K key,
DataContainer.ComputeAction<K,V> action) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.compute(K key,
DataContainer.ComputeAction<K,V> action) |
InternalCacheEntry |
InternalEntryFactoryImpl.create(CacheEntry cacheEntry) |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.create(CacheEntry<K,V> cacheEntry)
Creates a new
InternalCacheEntry instance based on the key, value, version and timestamp/lifespan
information reflected in the CacheEntry 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 new
InternalCacheEntry instance |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.create(K key,
V value,
InternalCacheEntry<?,?> cacheEntry)
Creates a new
InternalCacheEntry instance based on the version and timestamp/lifespan
information reflected in the CacheEntry instance passed in. |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.create(K key,
V value,
Metadata metadata)
Creates a new
InternalCacheEntry instance |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.create(K key,
V value,
Metadata metadata,
long lifespan,
long maxIdle)
Creates a new
InternalCacheEntry instance |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.create(K key,
V value,
Metadata metadata,
long created,
long lifespan,
long lastUsed,
long maxIdle)
Creates a new
InternalCacheEntry instance |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion version,
long created,
long lifespan,
long lastUsed,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
InternalCacheEntry cacheEntry) |
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) |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.createL1(K key,
V value,
Metadata metadata)
Creates a L1 entry.
|
<K,V> InternalCacheEntry |
InternalEntryFactoryImpl.createL1(K key,
V value,
Metadata metadata) |
InternalCacheEntry<K,V> |
AbstractDelegatingInternalDataContainer.get(int segment,
Object k) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.get(int segment,
Object k) |
InternalCacheEntry<K,V> |
InternalDataContainer.get(int segment,
Object k)
Deprecated.
since 10.1
|
InternalCacheEntry<K,V> |
AbstractDelegatingInternalDataContainer.get(Object k) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.get(Object k) |
InternalCacheEntry<K,V> |
InternalDataContainer.get(Object k)
Deprecated.
since 10.1
|
protected InternalCacheEntry<K,V> |
AbstractInternalDataContainer.EntryIterator.getNext() |
InternalCacheEntry<K,V> |
AbstractDelegatingInternalDataContainer.peek(int segment,
Object k) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.peek(int segment,
Object k) |
InternalCacheEntry<K,V> |
InternalDataContainer.peek(int segment,
Object k)
Same as
DataContainer.peek(Object) except that the segment of the key can provided to lookup entries
without calculating the segment for the given key |
InternalCacheEntry<K,V> |
AbstractDelegatingInternalDataContainer.peek(Object k) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.peek(Object k) |
InternalCacheEntry<K,V> |
BoundedSegmentedDataContainer.peek(Object k) |
InternalCacheEntry<K,V> |
PeekableTouchableCaffeineMap.peek(Object key) |
InternalCacheEntry<K,V> |
PeekableTouchableContainerMap.peek(Object key) |
InternalCacheEntry<K,V> |
PeekableTouchableMap.peek(Object key)
Peaks at a value for the given key.
|
InternalCacheEntry<K,V> |
AbstractDelegatingInternalDataContainer.remove(int segment,
Object k) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.remove(int segment,
Object k) |
InternalCacheEntry<K,V> |
InternalDataContainer.remove(int segment,
Object k)
Same as
DataContainer.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> |
AbstractDelegatingInternalDataContainer.remove(Object k) |
InternalCacheEntry<K,V> |
AbstractInternalDataContainer.remove(Object k) |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.update(InternalCacheEntry<K,V> cacheEntry,
Metadata metadata)
TODO: Adjust javadoc
Updates an existing
InternalCacheEntry with new metadata. |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.update(InternalCacheEntry<K,V> cacheEntry,
V value,
Metadata metadata)
Similar to
InternalEntryFactory.update(org.infinispan.container.entries.InternalCacheEntry, org.infinispan.metadata.Metadata)
but it also updates the InternalCacheEntry value. |
InternalCacheEntry |
InternalEntryFactoryImpl.update(InternalCacheEntry ice,
Metadata metadata) |
InternalCacheEntry |
InternalEntryFactoryImpl.update(InternalCacheEntry cacheEntry,
Object value,
Metadata metadata) |
| Modifier and Type | Method and Description |
|---|---|
protected 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.container.impl.AbstractInternalDataContainer.DefaultEvictionListener listener,
com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter) |
protected ConcurrentMap<K,InternalCacheEntry<K,V>> |
PeekableTouchableCaffeineMap.delegate() |
protected ConcurrentMap<K,InternalCacheEntry<K,V>> |
PeekableTouchableContainerMap.delegate() |
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.
|
Iterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.iterator() |
Iterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.iterator() |
Iterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.iterator() |
Iterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.iterator(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.iterator(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.iterator(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
InternalDataContainer.iterator(IntSet segments)
Same as
DataContainer.iterator() except that only entries that map to the provided segments are
returned via the iterator. |
Iterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.iteratorIncludingExpired() |
Iterator<InternalCacheEntry<K,V>> |
BoundedSegmentedDataContainer.iteratorIncludingExpired() |
Iterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.iteratorIncludingExpired() |
Iterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.iteratorIncludingExpired() |
Iterator<InternalCacheEntry<K,V>> |
L1SegmentedDataContainer.iteratorIncludingExpired() |
Iterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.iteratorIncludingExpired(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
BoundedSegmentedDataContainer.iteratorIncludingExpired(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.iteratorIncludingExpired(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.iteratorIncludingExpired(IntSet segments) |
Iterator<InternalCacheEntry<K,V>> |
InternalDataContainer.iteratorIncludingExpired(IntSet segments)
Same as
DataContainer.iteratorIncludingExpired() except that only entries that map to the provided
segments are returned via the iterator. |
Iterator<InternalCacheEntry<K,V>> |
L1SegmentedDataContainer.iteratorIncludingExpired(IntSet segments) |
org.reactivestreams.Publisher<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.publisher(int segment) |
default org.reactivestreams.Publisher<InternalCacheEntry<K,V>> |
InternalDataContainer.publisher(int segment) |
Spliterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.spliterator() |
Spliterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.spliterator() |
Spliterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.spliterator() |
Spliterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.spliterator(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.spliterator(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.spliterator(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
InternalDataContainer.spliterator(IntSet segments)
Same as
DataContainer.spliterator() except that only entries that map to the provided segments are
returned via this spliterator. |
Spliterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.spliteratorIncludingExpired() |
Spliterator<InternalCacheEntry<K,V>> |
BoundedSegmentedDataContainer.spliteratorIncludingExpired() |
Spliterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.spliteratorIncludingExpired() |
Spliterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.spliteratorIncludingExpired() |
Spliterator<InternalCacheEntry<K,V>> |
L1SegmentedDataContainer.spliteratorIncludingExpired() |
Spliterator<InternalCacheEntry<K,V>> |
AbstractDelegatingInternalDataContainer.spliteratorIncludingExpired(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
BoundedSegmentedDataContainer.spliteratorIncludingExpired(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.spliteratorIncludingExpired(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
DefaultSegmentedDataContainer.spliteratorIncludingExpired(IntSet segments) |
Spliterator<InternalCacheEntry<K,V>> |
InternalDataContainer.spliteratorIncludingExpired(IntSet segments)
Same as
DataContainer.spliteratorIncludingExpired() except that only entries that map to the provided
segments are returned via this spliterator. |
Spliterator<InternalCacheEntry<K,V>> |
L1SegmentedDataContainer.spliteratorIncludingExpired(IntSet segments) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractInternalDataContainer.computeEntryRemoved(K key,
InternalCacheEntry<K,V> value)
This method is invoked every time an entry is removed inside a compute block
|
protected 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 block
|
protected void |
BoundedSegmentedDataContainer.computeEntryWritten(K key,
InternalCacheEntry<K,V> value) |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.create(K key,
V value,
InternalCacheEntry<?,?> cacheEntry)
Creates a new
InternalCacheEntry instance based on the version and timestamp/lifespan
information reflected in the CacheEntry instance passed in. |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
InternalCacheEntry cacheEntry) |
static <K,V> CompletionStage<Void> |
AbstractInternalDataContainer.handleEviction(InternalCacheEntry<K,V> entry,
DataOperationOrderer orderer,
PassivationManager passivator,
EvictionManager<K,V> evictionManager,
DataContainer<K,V> dataContainer,
CompletionStage<Void> selfDelay)
Performs the eviction logic, except it doesn't actually remove the entry from the data container.
|
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 existing
InternalCacheEntry with new metadata. |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.update(InternalCacheEntry<K,V> cacheEntry,
V value,
Metadata metadata)
Similar to
InternalEntryFactory.update(org.infinispan.container.entries.InternalCacheEntry, org.infinispan.metadata.Metadata)
but it also updates the InternalCacheEntry value. |
InternalCacheEntry |
InternalEntryFactoryImpl.update(InternalCacheEntry ice,
Metadata metadata) |
InternalCacheEntry |
InternalEntryFactoryImpl.update(InternalCacheEntry cacheEntry,
Object value,
Metadata metadata) |
| Modifier and Type | Method and 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 whenever
InternalDataContainer.removeSegments(IntSet) is invoked providing a way for
the listener to see what actual entries were removed from the container. |
protected 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.container.impl.AbstractInternalDataContainer.DefaultEvictionListener listener,
com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter) |
protected 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.container.impl.AbstractInternalDataContainer.DefaultEvictionListener listener,
com.github.benmanes.caffeine.cache.CacheWriter<K,InternalCacheEntry<K,V>> additionalWriter) |
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 |
AbstractDelegatingInternalDataContainer.forEach(Consumer<? super InternalCacheEntry<K,V>> action) |
void |
AbstractDelegatingInternalDataContainer.forEach(IntSet segments,
Consumer<? super InternalCacheEntry<K,V>> action) |
void |
DefaultSegmentedDataContainer.forEach(IntSet segments,
Consumer<? super InternalCacheEntry<K,V>> action) |
default void |
InternalDataContainer.forEach(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.
|
| Constructor and Description |
|---|
BoundedSegmentedDataContainer(int numSegments,
long thresholdSize,
EntrySizeCalculator<? super K,? super InternalCacheEntry<K,V>> sizeCalculator) |
DefaultDataContainer(long thresholdSize,
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.
|
EntryIterator(Iterator<InternalCacheEntry<K,V>> it) |
PeekableTouchableCaffeineMap(com.github.benmanes.caffeine.cache.Cache<K,InternalCacheEntry<K,V>> cache) |
PeekableTouchableContainerMap(ConcurrentMap<K,InternalCacheEntry<K,V>> map) |
| Modifier and Type | Field and Description |
|---|---|
protected List<Consumer<Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>>> |
BoundedOffHeapDataContainer.listeners |
| Modifier and Type | Method and Description |
|---|---|
void |
BoundedOffHeapDataContainer.addRemovalListener(Consumer<Iterable<InternalCacheEntry<WrappedBytes,WrappedBytes>>> listener) |
InternalCacheEntry<WrappedBytes,WrappedBytes> |
OffHeapConcurrentMap.compute(WrappedBytes key,
BiFunction<? super WrappedBytes,? super InternalCacheEntry<WrappedBytes,WrappedBytes>,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> remappingFunction) |
InternalCacheEntry<WrappedBytes,WrappedBytes> |
OffHeapConcurrentMap.compute(WrappedBytes key,
BiFunction<? super WrappedBytes,? super InternalCacheEntry<WrappedBytes,WrappedBytes>,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> remappingFunction) |
void |
OffHeapConcurrentMap.putAll(Map<? extends WrappedBytes,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> m) |
| Modifier and Type | Method and Description |
|---|---|
void |
RemoteValueRetrievedListener.remoteValueFound(InternalCacheEntry ice)
Invoked when a remote value is found from a remote source
|
| Modifier and Type | Method and Description |
|---|---|
void |
L1ManagerImpl.remoteValueFound(InternalCacheEntry ice) |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<Void> |
PassivationManagerStub.passivateAsync(InternalCacheEntry entry) |
CompletionStage<Void> |
PassivationManager.passivateAsync(InternalCacheEntry<?,?> entry)
Passivates the entry in a non blocking fashion.
|
CompletionStage<Void> |
PassivationManagerImpl.passivateAsync(InternalCacheEntry<?,?> entry) |
| Modifier and Type | Method and Description |
|---|---|
void |
ExpirationManager.handleInMemoryExpiration(InternalCacheEntry<K,V> entry,
long currentTime)
Deprecated.
since 9.3 this method is not intended for external use
|
| Modifier and Type | Method and Description |
|---|---|
protected CompletionStage<Boolean> |
ClusterExpirationManager.checkExpiredMaxIdle(InternalCacheEntry ice,
int segment) |
protected CompletionStage<Boolean> |
ExpirationManagerImpl.checkExpiredMaxIdle(InternalCacheEntry entry,
int segment)
Response is whether the value should be treated as expired.
|
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 to
InternalExpirationManager.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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
L1WriteSynchronizer.runL1UpdateIfPossible(InternalCacheEntry ice)
Attempts to the L1 update and set the value.
|
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<InternalCacheEntry<K,V>> |
CacheLoaderInterceptor.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd) |
CompletionStage<InternalCacheEntry<K,V>> |
PassivationCacheLoaderInterceptor.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd) |
CompletionStage<InternalCacheEntry<K,V>> |
PassivationClusteredCacheLoaderInterceptor.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd) |
| Modifier and Type | Method and Description |
|---|---|
void |
TransactionalExceptionEvictionInterceptor.accept(Iterable<InternalCacheEntry<Object,Object>> entries) |
| Constructor and Description |
|---|
InternalMetadataImpl(InternalCacheEntry ice)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.convert(MarshallableEntry<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,
TimeService timeService,
DataContainer.ComputeAction<K,V> action)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
int segment,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded)
Deprecated.
since 9.4 This method references PersistenceManager, which isn't a public class
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> Set<InternalCacheEntry<K,V>> |
PersistenceUtil.toEntrySet(AdvancedCacheLoader<K,V> acl,
Predicate<? super K> filter,
InternalEntryFactory ief) |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.convert(MarshallableEntry<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,
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,
TimeService timeService,
AtomicReference<Boolean> isLoaded) |
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded) |
| Modifier and Type | Method and Description |
|---|---|
default MarshallableEntry<K,V> |
MarshallableEntryFactory.create(InternalCacheEntry<K,V> e)
Creates a
MarshallableEntry instance from an InternalCacheEntry. |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<InternalCacheEntry<K,V>> |
EntryLoader.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd)
Load and store the entry if present in the data container, returning the entry in the CompletionStage
|
default CompletionStage<InternalCacheEntry<K,V>> |
EntryLoader.loadAndStoreInDataContainer(K key,
int segment)
Load and store the entry if present in the data container, returning the entry in the CompletionStage.
|
| Modifier and Type | Field and Description |
|---|---|
protected BlockingQueue<InternalCacheEntry<?,?>> |
ScatteredStateConsumerImpl.backupQueue |
| Modifier and Type | Method and Description |
|---|---|
Collection<InternalCacheEntry<?,?>> |
StateChunk.getCacheEntries() |
protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> |
StateProviderImpl.publishDataContainerEntries(IntSet segments) |
protected io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> |
StateProviderImpl.publishStoreEntries(IntSet segments) |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<Void> |
OutboundTransferTask.execute(io.reactivex.rxjava3.core.Flowable<InternalCacheEntry<Object,Object>> entries)
Starts sending entries from the data container and the first loader with fetch persistent data enabled
to the target node.
|
| Constructor and Description |
|---|
StateChunk(int segmentId,
Collection<InternalCacheEntry<?,?>> cacheEntries,
boolean isLastChunk) |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> InternalCacheEntry<K,V> |
CoreImmutables.immutableInternalCacheEntry(InternalCacheEntry<K,V> entry)
Wraps a
InternalCacheEntry} with an immutable InternalCacheEntry}. |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> InternalCacheEntry<K,V> |
CoreImmutables.immutableInternalCacheEntry(InternalCacheEntry<K,V> entry)
Wraps a
InternalCacheEntry} with an immutable InternalCacheEntry}. |
| Modifier and Type | Method and Description |
|---|---|
static XSiteState |
XSiteState.fromDataContainer(InternalCacheEntry<?,?> entry) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.