Package | Description |
---|---|
org.infinispan.distexec.mapreduce |
Map/Reduce APIs
|
org.infinispan.expiration |
Classes related to entry expiration.
|
org.infinispan.expiration.impl | |
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.marshall.core | |
org.infinispan.persistence |
This package contains stores, which are used for overflow or persistence.
|
org.infinispan.persistence.async | |
org.infinispan.persistence.cluster |
A
CacheLoader (not CacheWriter ) that polls other nodes in the cluster for state. |
org.infinispan.persistence.file |
Simple filesystem-based
CacheWriter implementation. |
org.infinispan.persistence.manager | |
org.infinispan.persistence.modifications |
Modifications that are used to encapsulate cache operations for application to a
CacheStore . |
org.infinispan.persistence.spi |
The Persistence SPI
|
org.infinispan.persistence.support | |
org.infinispan.xsite.statetransfer |
Modifier and Type | Method and Description |
---|---|
void |
MapReduceCacheLoaderTask.processEntry(MarshalledEntry<KIn,VIn> marshalledEntry,
AdvancedCacheLoader.TaskContext taskContext) |
Modifier and Type | Method and Description |
---|---|
void |
ExpirationManager.handleInStoreExpiration(MarshalledEntry<K,V> marshalledEntry)
This is to be invoked when a store entry expires and the value and/or metadata is available to be used.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterExpirationManager.handleInStoreExpiration(MarshalledEntry<K,V> marshalledEntry) |
void |
ExpirationManagerImpl.handleInStoreExpiration(MarshalledEntry<K,V> marshalledEntry) |
Modifier and Type | Method and Description |
---|---|
void |
LocalEntryRetriever.KeyValueActionForCacheLoaderTask.processEntry(MarshalledEntry<K,V> marshalledEntry,
AdvancedCacheLoader.TaskContext taskContext) |
Modifier and Type | Class and Description |
---|---|
class |
MarshalledEntryImpl<K,V> |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry |
MarshalledEntryFactoryImpl.newMarshalledEntry(org.infinispan.commons.io.ByteBuffer key,
org.infinispan.commons.io.ByteBuffer valueBytes,
org.infinispan.commons.io.ByteBuffer metadataBytes) |
MarshalledEntry<K,V> |
MarshalledEntryFactory.newMarshalledEntry(org.infinispan.commons.io.ByteBuffer key,
org.infinispan.commons.io.ByteBuffer valueBytes,
org.infinispan.commons.io.ByteBuffer metadataBytes) |
MarshalledEntry |
MarshalledEntryFactoryImpl.newMarshalledEntry(Object key,
org.infinispan.commons.io.ByteBuffer valueBytes,
org.infinispan.commons.io.ByteBuffer metadataBytes) |
MarshalledEntry<K,V> |
MarshalledEntryFactory.newMarshalledEntry(Object key,
org.infinispan.commons.io.ByteBuffer valueBytes,
org.infinispan.commons.io.ByteBuffer metadataBytes) |
MarshalledEntry |
MarshalledEntryFactoryImpl.newMarshalledEntry(Object key,
Object value,
InternalMetadata im) |
MarshalledEntry<K,V> |
MarshalledEntryFactory.newMarshalledEntry(Object key,
Object value,
InternalMetadata im) |
Modifier and Type | Method and Description |
---|---|
static MarshalledEntry |
PersistenceUtil.loadAndCheckExpiration(PersistenceManager persistenceManager,
Object key,
InvocationContext context,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.convert(MarshalledEntry<K,V> loaded,
InternalEntryFactory factory) |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry |
AsyncCacheLoader.load(Object key) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncCacheWriter.write(MarshalledEntry entry) |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry |
ClusterLoader.load(Object key) |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry<K,V> |
SingleFileStore.load(Object key) |
Modifier and Type | Method and Description |
---|---|
void |
SingleFileStore.write(MarshalledEntry<? extends K,? extends V> marshalledEntry) |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry |
PersistenceManagerStub.loadFromAllStores(Object key,
InvocationContext context) |
MarshalledEntry |
PersistenceManager.loadFromAllStores(Object key,
InvocationContext context) |
MarshalledEntry |
PersistenceManagerImpl.loadFromAllStores(Object key,
InvocationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
PersistenceManagerStub.writeToAllStores(MarshalledEntry marshalledEntry,
PersistenceManager.AccessMode modes) |
void |
PersistenceManager.writeToAllStores(MarshalledEntry marshalledEntry,
PersistenceManager.AccessMode modes) |
void |
PersistenceManagerImpl.writeToAllStores(MarshalledEntry marshalledEntry,
PersistenceManager.AccessMode mode) |
void |
PersistenceManagerStub.writeToAllStores(MarshalledEntry marshalledEntry,
PersistenceManager.AccessMode modes,
Set<Flag> flags) |
void |
PersistenceManager.writeToAllStores(MarshalledEntry marshalledEntry,
PersistenceManager.AccessMode modes,
Set<Flag> flags) |
void |
PersistenceManagerImpl.writeToAllStores(MarshalledEntry marshalledEntry,
PersistenceManager.AccessMode mode,
Set<Flag> flags) |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry |
Store.getStoredValue() |
Constructor and Description |
---|
Store(Object key,
MarshalledEntry storedValue) |
Modifier and Type | Method and Description |
---|---|
MarshalledEntry<K,V> |
CacheLoader.load(Object key)
Fetches an entry from the storage.
|
Modifier and Type | Method and Description |
---|---|
void |
AdvancedCacheExpirationWriter.ExpirationPurgeListener.marshalledEntryPurged(MarshalledEntry<K,V> entry)
Optional.
|
void |
AdvancedCacheLoader.CacheLoaderTask.processEntry(MarshalledEntry<K,V> marshalledEntry,
AdvancedCacheLoader.TaskContext taskContext) |
void |
CacheWriter.write(MarshalledEntry<? extends K,? extends V> entry)
Persists the entry to the storage.
|
Modifier and Type | Method and Description |
---|---|
MarshalledEntry |
Bucket.getEntry(Object key,
TimeService timeService) |
MarshalledEntry |
DelegatingCacheLoader.load(Object key) |
Modifier and Type | Method and Description |
---|---|
Map<Object,MarshalledEntry> |
Bucket.getStoredEntries() |
Map<Object,MarshalledEntry> |
Bucket.getStoredEntries(KeyFilter filter,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
Bucket.addEntry(Object key,
MarshalledEntry sv) |
void |
SingletonCacheWriter.write(MarshalledEntry entry) |
void |
DelegatingCacheWriter.write(MarshalledEntry entry) |
Constructor and Description |
---|
Bucket(Map<Object,MarshalledEntry> entries,
org.infinispan.commons.equivalence.Equivalence<Object> keyEquivalence) |
Modifier and Type | Method and Description |
---|---|
static XSiteState |
XSiteState.fromCacheLoader(MarshalledEntry marshalledEntry) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.