Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.control |
Commands that control and coordinate certain cache operations, such as rehashing, state transfer and locking.
|
org.infinispan.commands.read |
Commands that read data from the cache.
|
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.container.entries |
Entries which are stored in data containers.
|
org.infinispan.container.entries.versioned | |
org.infinispan.distribution |
Classes relating to the distributed cache mode.
|
org.infinispan.eviction |
Classes related to eviction.
|
org.infinispan.loaders |
This package contains loaders and stores, which are used for overflow or persistence.
|
org.infinispan.loaders.bucket |
Abstract classes that use hashed buckets to store entries.
|
org.infinispan.loaders.cluster |
A
CacheLoader (not CacheStore ) that polls other nodes in the cluster for state. |
org.infinispan.loaders.decorators |
This package contains loaders and stores, which are used for overflow or persistence.
|
org.infinispan.loaders.modifications |
Modifications that are used to encapsulate cache operations for application to a
CacheStore . |
org.infinispan.notifications.cachelistener |
Cache -specific notifications and eventing. |
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.
|
Modifier and Type | Method and Description |
---|---|
StateTransferControlCommand |
CommandsFactoryImpl.buildStateTransferCommand(StateTransferControlCommand.Type type,
Address sender,
int viewId,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
StateTransferControlCommand |
CommandsFactory.buildStateTransferCommand(StateTransferControlCommand.Type subtype,
Address sender,
int viewId,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo)
Builds a RehashControlCommand for coordinating a rehash event.
|
Constructor and Description |
---|
StateTransferControlCommand(String cacheName,
StateTransferControlCommand.Type type,
Address sender,
int viewId,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
Modifier and Type | Method and Description |
---|---|
Set<InternalCacheEntry> |
EntrySetCommand.perform(InvocationContext ctx) |
Constructor and Description |
---|
ValuesCommand.ExpiredFilteredValues(Set<InternalCacheEntry> entrySet) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Object,InternalCacheEntry> |
DefaultDataContainer.entries |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
InternalEntryFactoryImpl.create(CacheEntry cacheEntry) |
InternalCacheEntry |
InternalEntryFactory.create(CacheEntry cacheEntry)
Creates a new
InternalCacheEntry instance based on the key, value, version and timestamp/lifespan
information reflected in the CacheEntry instance passed in. |
InternalCacheEntry |
VersionedInternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion version) |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion ignored) |
InternalCacheEntry |
InternalEntryFactory.create(Object key,
Object value,
EntryVersion version)
Creates a new
InternalCacheEntry instance |
InternalCacheEntry |
VersionedInternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion version,
long lifespan,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion ignored,
long lifespan,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactory.create(Object key,
Object value,
EntryVersion version,
long lifespan,
long maxIdle)
Creates a new
InternalCacheEntry instance |
InternalCacheEntry |
VersionedInternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion version,
long created,
long lifespan,
long lastUsed,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
EntryVersion ignored,
long created,
long lifespan,
long lastUsed,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactory.create(Object key,
Object value,
EntryVersion version,
long created,
long lifespan,
long lastUsed,
long maxIdle)
Creates a new
InternalCacheEntry instance |
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
InternalCacheEntry cacheEntry) |
InternalCacheEntry |
InternalEntryFactory.create(Object key,
Object value,
InternalCacheEntry cacheEntry)
Creates a new
InternalCacheEntry instance based on the version and timestamp/lifespan
information reflected in the CacheEntry instance passed in. |
InternalCacheEntry |
DefaultDataContainer.get(Object k) |
InternalCacheEntry |
DataContainer.get(Object k)
Retrieves a cached entry
|
InternalCacheEntry |
DefaultDataContainer.EntryIterator.next() |
InternalCacheEntry |
DefaultDataContainer.peek(Object key) |
InternalCacheEntry |
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 |
DefaultDataContainer.remove(Object k) |
InternalCacheEntry |
DataContainer.remove(Object k)
Removes an entry from the cache
|
InternalCacheEntry |
VersionedInternalEntryFactoryImpl.update(InternalCacheEntry ice,
long lifespan,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactoryImpl.update(InternalCacheEntry ice,
long lifespan,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactory.update(InternalCacheEntry cacheEntry,
long lifespan,
long maxIdle)
Updates an existing
InternalCacheEntry with new lifespan and maxIdle values. |
Modifier and Type | Method and Description |
---|---|
Set<InternalCacheEntry> |
DefaultDataContainer.entrySet() |
Set<InternalCacheEntry> |
DataContainer.entrySet()
Returns a mutable set of immutable cache entries exposed as immutable Map.Entry instances.
|
Iterator<InternalCacheEntry> |
DefaultDataContainer.iterator() |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
InternalEntryFactoryImpl.create(Object key,
Object value,
InternalCacheEntry cacheEntry) |
InternalCacheEntry |
InternalEntryFactory.create(Object key,
Object value,
InternalCacheEntry cacheEntry)
Creates a new
InternalCacheEntry instance based on the version and timestamp/lifespan
information reflected in the CacheEntry instance passed in. |
InternalCacheEntry |
VersionedInternalEntryFactoryImpl.update(InternalCacheEntry ice,
long lifespan,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactoryImpl.update(InternalCacheEntry ice,
long lifespan,
long maxIdle) |
InternalCacheEntry |
InternalEntryFactory.update(InternalCacheEntry cacheEntry,
long lifespan,
long maxIdle)
Updates an existing
InternalCacheEntry with new lifespan and maxIdle values. |
MVCCEntry |
EntryFactoryImpl.wrapEntryForPut(InvocationContext ctx,
Object key,
InternalCacheEntry icEntry,
boolean undeleteIfNeeded) |
MVCCEntry |
EntryFactory.wrapEntryForPut(InvocationContext ctx,
Object key,
InternalCacheEntry ice,
boolean undeleteIfNeeded)
Used for wrapping a cache entry for addition to cache.
|
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 |
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 |
InternalCacheEntry.clone() |
InternalCacheEntry |
TransientMortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
TransientCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
MortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
InternalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
ImmortalCacheValue.toInternalCacheEntry(Object key) |
Modifier and Type | Class and Description |
---|---|
class |
VersionedImmortalCacheEntry
A form of
ImmortalCacheEntry that is Versioned |
class |
VersionedMortalCacheEntry
A form of
MortalCacheEntry that is Versioned |
class |
VersionedTransientCacheEntry
A form of
TransientCacheEntry that is Versioned |
class |
VersionedTransientMortalCacheEntry
A form of
TransientMortalCacheEntry that is Versioned |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
VersionedTransientMortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
VersionedTransientCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
VersionedMortalCacheValue.toInternalCacheEntry(Object key) |
InternalCacheEntry |
VersionedImmortalCacheValue.toInternalCacheEntry(Object key) |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
DistributionManagerImpl.retrieveFromRemoteSource(Object key,
InvocationContext ctx,
boolean acquireRemoteLock) |
InternalCacheEntry |
DistributionManager.retrieveFromRemoteSource(Object key,
InvocationContext ctx,
boolean acquireRemoteLock)
Retrieves a cache entry from a remote source.
|
Modifier and Type | Method and Description |
---|---|
void |
PassivationManagerImpl.passivate(InternalCacheEntry entry) |
void |
PassivationManager.passivate(InternalCacheEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
EvictionManagerImpl.onEntryEviction(Map<Object,InternalCacheEntry> evicted) |
void |
EvictionManager.onEntryEviction(Map<Object,InternalCacheEntry> evicted) |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
LockSupportCacheStore.load(Object key) |
InternalCacheEntry |
CacheLoader.load(Object key)
Loads an entry mapped to by a given key.
|
protected abstract InternalCacheEntry |
LockSupportCacheStore.loadLockSafe(Object key,
L lockingKey) |
Modifier and Type | Method and Description |
---|---|
Set<InternalCacheEntry> |
LockSupportCacheStore.load(int maxEntries) |
Set<InternalCacheEntry> |
CacheLoader.load(int numEntries)
Loads up to a specific number of entries.
|
Set<InternalCacheEntry> |
LockSupportCacheStore.loadAll() |
Set<InternalCacheEntry> |
CacheLoader.loadAll()
Loads all entries in the loader.
|
protected abstract Set<InternalCacheEntry> |
LockSupportCacheStore.loadAllLockSafe() |
protected abstract Set<InternalCacheEntry> |
LockSupportCacheStore.loadLockSafe(int maxEntries) |
Modifier and Type | Method and Description |
---|---|
void |
LockSupportCacheStore.store(InternalCacheEntry ed) |
void |
CacheStore.store(InternalCacheEntry entry)
Stores an entry
|
protected abstract void |
LockSupportCacheStore.storeLockSafe(InternalCacheEntry ed,
L lockingKey) |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
Bucket.getEntry(Object key) |
protected InternalCacheEntry |
BucketBasedCacheStore.loadLockSafe(Object key,
Integer lockingKey)
Loads an entry from a Bucket, locating the relevant Bucket using the key's hash code.
|
Modifier and Type | Method and Description |
---|---|
Map<Object,InternalCacheEntry> |
Bucket.getEntries() |
Collection<? extends InternalCacheEntry> |
Bucket.getStoredEntries() |
protected Set<InternalCacheEntry> |
BucketBasedCacheStore.loadAllLockSafe() |
protected Set<InternalCacheEntry> |
BucketBasedCacheStore.loadLockSafe(int max) |
Modifier and Type | Method and Description |
---|---|
void |
Bucket.addEntry(InternalCacheEntry se) |
protected void |
BucketBasedCacheStore.storeLockSafe(InternalCacheEntry entry,
Integer lockingKey)
Stores an entry in an appropriate Bucket, based on the key's hash code.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
BucketBasedCacheStore.CollectionGeneratingBucketHandler.consider(Collection<? extends InternalCacheEntry> entries) |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
ClusterCacheLoader.load(Object key) |
Modifier and Type | Method and Description |
---|---|
Set<InternalCacheEntry> |
ClusterCacheLoader.load(int maxElems) |
Set<InternalCacheEntry> |
ClusterCacheLoader.loadAll() |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
ChainingCacheStore.load(Object key) |
InternalCacheEntry |
AbstractDelegatingStore.load(Object key) |
Modifier and Type | Method and Description |
---|---|
Set<InternalCacheEntry> |
ChainingCacheStore.load(int numEntries) |
Set<InternalCacheEntry> |
AbstractDelegatingStore.load(int numEntries) |
Set<InternalCacheEntry> |
ChainingCacheStore.loadAll() |
Set<InternalCacheEntry> |
AbstractDelegatingStore.loadAll() |
Modifier and Type | Method and Description |
---|---|
void |
SingletonStore.store(InternalCacheEntry ed) |
void |
ReadOnlyStore.store(InternalCacheEntry ed) |
void |
ChainingCacheStore.store(InternalCacheEntry ed) |
void |
AsyncStore.store(InternalCacheEntry ed) |
void |
AbstractDelegatingStore.store(InternalCacheEntry ed) |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry |
Store.getStoredEntry() |
Constructor and Description |
---|
Store(InternalCacheEntry storedEntry) |
Modifier and Type | Method and Description |
---|---|
void |
CacheNotifierImpl.notifyCacheEntriesEvicted(Collection<InternalCacheEntry> entries,
InvocationContext ctx) |
void |
CacheNotifier.notifyCacheEntriesEvicted(Collection<InternalCacheEntry> entries,
InvocationContext ctx)
Notifies all registered listeners of a CacheEntriesEvicted event.
|
Modifier and Type | Method and Description |
---|---|
void |
StateTransferManager.applyState(Collection<InternalCacheEntry> state,
Address sender,
int viewId) |
void |
BaseStateTransferManagerImpl.applyState(Collection<InternalCacheEntry> state,
Address sender,
int viewId) |
protected void |
BaseStateTransferTask.pushPartialState(Collection<Address> targets,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
void |
BaseStateTransferManagerImpl.pushStateToNode(NotifyingNotifiableFuture<Object> stateTransferFuture,
int viewId,
Collection<Address> targets,
Collection<InternalCacheEntry> state,
Collection<LockInfo> lockInfo) |
Modifier and Type | Method and Description |
---|---|
static InternalCacheEntry |
Immutables.immutableInternalCacheEntry(InternalCacheEntry entry)
Wraps a
InternalCacheEntry } with an immutable InternalCacheEntry }. |
Modifier and Type | Method and Description |
---|---|
static InternalCacheEntry |
Immutables.immutableInternalCacheEntry(InternalCacheEntry entry)
Wraps a
InternalCacheEntry } with an immutable InternalCacheEntry }. |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.