Package | Description |
---|---|
org.infinispan.cache.impl | |
org.infinispan.commands.functional | |
org.infinispan.commands.read | |
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.container.entries |
Entries which are stored in data containers.
|
org.infinispan.container.entries.metadata | |
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 |
Classes related to entry expiration.
|
org.infinispan.expiration.impl | |
org.infinispan.interceptors.distribution | |
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.metadata.impl | |
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
org.infinispan.persistence |
This package contains stores, which are used for overflow or persistence.
|
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 |
---|---|
Map<Object,InternalCacheEntry> |
ReadOnlyManyCommand.getRemotelyFetched() |
Modifier and Type | Method and Description |
---|---|
void |
ReadOnlyManyCommand.setRemotelyFetched(Map<Object,InternalCacheEntry> remotelyFetched) |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
GetCacheEntryCommand.getRemotelyFetchedValue()
If the cache needs to go remotely in order to obtain the value associated to this key, then the remote value
is stored in this field.
|
InternalCacheEntry |
RemoteFetchingCommand.getRemotelyFetchedValue()
Deprecated.
If the cache needs to go remotely in order to obtain the value associated to this key, then the remote value
is stored in this field.
|
InternalCacheEntry |
GetKeyValueCommand.getRemotelyFetchedValue()
If the cache needs to go remotely in order to obtain the value associated to this key, then the remote value
is stored in this field.
|
Modifier and Type | Method and Description |
---|---|
Map<Object,InternalCacheEntry> |
GetAllCommand.getRemotelyFetched() |
Modifier and Type | Method and Description |
---|---|
void |
GetCacheEntryCommand.setRemotelyFetchedValue(InternalCacheEntry remotelyFetchedValue) |
void |
RemoteFetchingCommand.setRemotelyFetchedValue(InternalCacheEntry remotelyFetchedValue)
Deprecated.
|
void |
GetKeyValueCommand.setRemotelyFetchedValue(InternalCacheEntry remotelyFetchedValue) |
Modifier and Type | Method and Description |
---|---|
void |
GetAllCommand.setRemotelyFetched(Map<Object,InternalCacheEntry> remotelyFetched) |
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> |
DefaultDataContainer.compute(K key,
DataContainer.ComputeAction<K,V> action) |
InternalCacheEntry<K,V> |
DataContainer.ComputeAction.compute(K key,
InternalCacheEntry<K,V> oldEntry,
InternalEntryFactory factory)
Computes the new value for the key.
|
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 |
InternalEntryFactoryImpl.createL1(K key,
V value,
Metadata metadata) |
<K,V> InternalCacheEntry<K,V> |
InternalEntryFactory.createL1(K key,
V value,
Metadata metadata)
Creates a L1 entry.
|
InternalCacheEntry<K,V> |
DataContainer.get(Object k)
Retrieves a cached entry
|
InternalCacheEntry<K,V> |
DefaultDataContainer.get(Object k) |
InternalCacheEntry<K,V> |
DefaultDataContainer.EntryIterator.next() |
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> |
DefaultDataContainer.peek(Object key) |
InternalCacheEntry<K,V> |
DataContainer.remove(Object k)
Removes an entry from the cache
The
key must be activate by invoking ActivationManager.onRemove(Object,
boolean) . |
InternalCacheEntry<K,V> |
DefaultDataContainer.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 |
---|---|
Set<InternalCacheEntry<K,V>> |
DataContainer.entrySet()
Returns a mutable set of immutable cache entries exposed as immutable Map.Entry instances.
|
Set<InternalCacheEntry<K,V>> |
DefaultDataContainer.entrySet() |
Iterator<InternalCacheEntry<K,V>> |
DataContainer.iterator() |
Iterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.iterator() |
Iterator<InternalCacheEntry<K,V>> |
DataContainer.iteratorIncludingExpired()
Same as
DataContainer.iterator() except that is also returns expired entries. |
Iterator<InternalCacheEntry<K,V>> |
DefaultDataContainer.iteratorIncludingExpired() |
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.
|
<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) |
<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) |
MVCCEntry |
EntryFactoryImpl.wrapEntryForPut(InvocationContext ctx,
Object key,
InternalCacheEntry icEntry,
boolean undeleteIfNeeded,
FlagAffectedCommand cmd,
boolean skipRead) |
MVCCEntry |
EntryFactory.wrapEntryForPut(InvocationContext ctx,
Object key,
InternalCacheEntry ice,
boolean undeleteIfNeeded,
FlagAffectedCommand cmd,
boolean skipRead)
Deprecated.
Since 8.1, use
EntryFactory.wrapEntryForWriting(InvocationContext, Object, Wrap, boolean, boolean) instead. |
Modifier and Type | Method and Description |
---|---|
void |
DataContainer.executeTask(KeyFilter<? super K> filter,
BiConsumer<? super K,InternalCacheEntry<K,V>> action)
Executes task specified by the given action on the container key/values filtered using the specified key filter.
|
void |
DefaultDataContainer.executeTask(KeyFilter<? super K> filter,
BiConsumer<? super K,InternalCacheEntry<K,V>> action) |
void |
DataContainer.executeTask(KeyValueFilter<? super K,? super V> filter,
BiConsumer<? super K,InternalCacheEntry<K,V>> action)
Executes task specified by the given action on the container key/values filtered using the specified keyvalue filter.
|
void |
DefaultDataContainer.executeTask(KeyValueFilter<? super K,? super V> filter,
BiConsumer<? super K,InternalCacheEntry<K,V>> action) |
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 |
TransientCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
MortalCacheValue.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 is Versioned |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
MetadataImmortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
MetadataTransientCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
MetadataMortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
MetadataTransientMortalCacheValue.toInternalCacheEntry(Object key) |
Modifier and Type | Method and Description |
---|---|
default boolean |
InvocationContext.replaceValue(Object key,
InternalCacheEntry cacheEntry)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractInvocationContext.onEntryValueReplaced(Object key,
InternalCacheEntry cacheEntry)
Deprecated.
Since 8.1, no longer used.
|
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 |
---|---|
void |
PassivationManager.passivate(InternalCacheEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
EvictionManager.onEntryEviction(Map<? extends K,InternalCacheEntry<? extends K,? extends V>> evicted)
Handles notifications of evicted entries
|
Modifier and Type | Method and Description |
---|---|
void |
PassivationManagerStub.passivate(InternalCacheEntry entry) |
void |
PassivationManagerImpl.passivate(InternalCacheEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
EvictionManagerImpl.onEntryEviction(Map<? extends K,InternalCacheEntry<? extends K,? extends V>> evicted) |
Modifier and Type | Method and Description |
---|---|
void |
ExpirationManager.handleInMemoryExpiration(InternalCacheEntry<K,V> entry,
long currentTime)
This should be invoked passing in an entry that is now expired.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterExpirationManager.handleInMemoryExpiration(InternalCacheEntry<K,V> entry,
long currentTime) |
void |
ExpirationManagerImpl.handleInMemoryExpiration(InternalCacheEntry<K,V> entry,
long currentTime) |
Modifier and Type | Method and Description |
---|---|
protected InternalCacheEntry |
BaseDistributionInterceptor.fetchValueLocallyIfAvailable(ConsistentHash consistentHash,
Object key)
Deprecated.
|
protected InternalCacheEntry |
TxDistributionInterceptor.remoteGet(InvocationContext ctx,
Object key,
boolean isWrite,
FlagAffectedCommand command)
Deprecated.
|
protected InternalCacheEntry |
BaseDistributionInterceptor.retrieveFromRemoteSource(Object key,
InvocationContext ctx,
boolean acquireRemoteLock,
FlagAffectedCommand command,
boolean isWrite)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Map<Object,InternalCacheEntry> |
BaseDistributionInterceptor.retrieveFromRemoteSources(Set<?> requestedKeys,
InvocationContext ctx,
Set<Flag> flags)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
L1WriteSynchronizer.runL1UpdateIfPossible(InternalCacheEntry ice)
Attempts to the L1 update and set the value.
|
Constructor and Description |
---|
DataContainerIterator(Iterator<InternalCacheEntry<K,V>> iterator,
KeyValueFilter<? super K,? super V> filter,
Converter<? super K,? super V,? extends C> converter,
boolean filterAndConvert) |
KeyValueActionForCacheLoaderTask(BiConsumer<? super K,? super InternalCacheEntry<K,V>> action) |
Constructor and Description |
---|
InternalMetadataImpl(InternalCacheEntry ice) |
Modifier and Type | Method and Description |
---|---|
void |
CacheNotifier.notifyCacheEntriesEvicted(Collection<InternalCacheEntry<? extends K,? extends V>> entries,
InvocationContext ctx,
FlagAffectedCommand command)
Notifies all registered listeners of a
CacheEntriesEvictedEvent event. |
void |
CacheNotifierImpl.notifyCacheEntriesEvicted(Collection<InternalCacheEntry<? extends K,? extends V>> entries,
InvocationContext ctx,
FlagAffectedCommand command) |
Modifier and Type | Method and Description |
---|---|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.convert(MarshalledEntry<K,V> loaded,
InternalEntryFactory factory) |
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 |
---|---|
static <K,V> Set<InternalCacheEntry> |
PersistenceUtil.toEntrySet(AdvancedCacheLoader<K,V> acl,
KeyFilter<? super K> filter,
InternalEntryFactory ief) |
Modifier and Type | Method and Description |
---|---|
static InternalMetadata |
PersistenceUtil.internalMetadata(InternalCacheEntry ice) |
Modifier and Type | Method and Description |
---|---|
Collection<InternalCacheEntry> |
StateChunk.getCacheEntries() |
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 © 2024 JBoss, a division of Red Hat. All rights reserved.