Package | Description |
---|---|
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.file |
Simple filesystem-based
CacheStore implementation. |
org.infinispan.loaders.jdbc |
This package contains a
CacheStore implementation based on
a JDBC database connection. |
org.infinispan.loaders.jdbc.binary |
This JDBC CacheStore implementation is optimized for storing binary (non-String)
keys in the cache.
|
org.infinispan.loaders.jdbc.connectionfactory |
Connection factories for use with the JDBC Cache Store.
|
org.infinispan.loaders.jdbc.mixed |
This is a delegating CacheStore implementation that delegates either to a binary
or String based JDBC cache store depending on the key used.
|
org.infinispan.loaders.jdbc.stringbased |
This JDBC CacheStore implementation is optimized for storing String
keys in the cache.
|
org.infinispan.loaders.keymappers | |
org.infinispan.loaders.remote | |
org.infinispan.util.logging |
Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
|
Modifier and Type | Method and Description |
---|---|
void |
PassivationManagerImpl.passivateAll() |
void |
PassivationManager.passivateAll() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractCacheStore.applyModifications(List<? extends Modification> mods) |
void |
LockSupportCacheStore.clear() |
void |
CacheStore.clear()
Clears all entries in the store
|
protected abstract void |
LockSupportCacheStore.clearLockSafe() |
void |
AbstractCacheStore.commit(GlobalTransaction tx) |
void |
CacheStore.commit(GlobalTransaction tx)
Commits a transaction that has been previously prepared.
|
boolean |
AbstractCacheLoader.containsKey(Object key)
This implementation delegates to
CacheLoader.load(Object) , to ensure that a response is
returned only if the entry is not expired. |
boolean |
CacheLoader.containsKey(Object key) |
void |
LockSupportCacheStore.fromStream(ObjectInput objectInput) |
void |
CacheStore.fromStream(ObjectInput inputStream)
Writes contents of the stream to the store.
|
protected abstract void |
LockSupportCacheStore.fromStreamLockSafe(ObjectInput ois) |
protected abstract L |
LockSupportCacheStore.getLockFromKey(Object key) |
void |
LockSupportCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AbstractCacheLoader.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AbstractCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
CacheLoader.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m)
Used to initialize a cache loader.
|
Set<InternalCacheEntry> |
LockSupportCacheStore.load(int maxEntries) |
Set<InternalCacheEntry> |
CacheLoader.load(int numEntries)
Loads up to a specific number of entries.
|
InternalCacheEntry |
LockSupportCacheStore.load(Object key) |
InternalCacheEntry |
CacheLoader.load(Object key)
Loads an entry mapped to by a given key.
|
Set<InternalCacheEntry> |
LockSupportCacheStore.loadAll() |
Set<InternalCacheEntry> |
CacheLoader.loadAll()
Loads all entries in the loader.
|
Set<Object> |
LockSupportCacheStore.loadAllKeys(Set<Object> keysToExclude) |
Set<Object> |
CacheLoader.loadAllKeys(Set<Object> keysToExclude)
Loads a set of all keys, excluding a filter set.
|
protected abstract Set<Object> |
LockSupportCacheStore.loadAllKeysLockSafe(Set<Object> keysToExclude) |
protected abstract Set<InternalCacheEntry> |
LockSupportCacheStore.loadAllLockSafe() |
protected abstract Set<InternalCacheEntry> |
LockSupportCacheStore.loadLockSafe(int maxEntries) |
protected abstract InternalCacheEntry |
LockSupportCacheStore.loadLockSafe(Object key,
L lockingKey) |
void |
AbstractCacheStore.prepare(List<? extends Modification> mods,
GlobalTransaction tx,
boolean isOnePhase) |
void |
CacheStore.prepare(List<? extends Modification> modifications,
GlobalTransaction tx,
boolean isOnePhase)
Issues a prepare call with a set of modifications to be applied to the cache store
|
void |
AbstractCacheStore.purgeExpired() |
void |
CacheStore.purgeExpired()
Purges expired entries from the store.
|
protected abstract void |
AbstractCacheStore.purgeInternal() |
boolean |
LockSupportCacheStore.remove(Object key) |
boolean |
CacheStore.remove(Object key)
Removes an entry in the store.
|
void |
AbstractCacheStore.removeAll(Set<Object> keys) |
void |
CacheStore.removeAll(Set<Object> keys)
Bulk remove operation
|
protected abstract boolean |
LockSupportCacheStore.removeLockSafe(Object key,
L lockingKey) |
protected static void |
AbstractCacheStore.safeClose(InputStream stream) |
protected static void |
AbstractCacheStore.safeClose(OutputStream stream) |
void |
LockSupportCacheStore.start() |
void |
AbstractCacheStore.start() |
void |
CacheLoader.start() |
void |
AbstractCacheStore.stop() |
void |
CacheLoader.stop() |
void |
LockSupportCacheStore.store(InternalCacheEntry ed) |
void |
CacheStore.store(InternalCacheEntry entry)
Stores an entry
|
protected abstract void |
LockSupportCacheStore.storeLockSafe(InternalCacheEntry ed,
L lockingKey) |
void |
LockSupportCacheStore.toStream(ObjectOutput objectOutput) |
void |
CacheStore.toStream(ObjectOutput outputStream)
Loads the entire state into a stream, using whichever format is most efficient for the cache loader
implementation.
|
protected abstract void |
LockSupportCacheStore.toStreamLockSafe(ObjectOutput oos) |
Modifier and Type | Method and Description |
---|---|
boolean |
BucketBasedCacheStore.BucketHandler.handle(Bucket bucket)
Handles a bucket that is passed in.
|
boolean |
BucketBasedCacheStore.CollectionGeneratingBucketHandler.handle(Bucket bucket) |
protected void |
BucketBasedCacheStore.insertBucket(Bucket bucket)
Inserts a new Bucket in the storage system.
|
protected Set<Object> |
BucketBasedCacheStore.loadAllKeysLockSafe(Set<Object> keysToExclude) |
protected Set<InternalCacheEntry> |
BucketBasedCacheStore.loadAllLockSafe() |
protected abstract Bucket |
BucketBasedCacheStore.loadBucket(Integer hash)
Loads a Bucket from the store, based on the hash code of the bucket.
|
protected Set<InternalCacheEntry> |
BucketBasedCacheStore.loadLockSafe(int max) |
protected InternalCacheEntry |
BucketBasedCacheStore.loadLockSafe(Object key,
Integer lockingKey)
Loads an entry from a Bucket, locating the relevant Bucket using the key's hash code.
|
protected abstract void |
BucketBasedCacheStore.loopOverBuckets(BucketBasedCacheStore.BucketHandler handler)
A mechanism to loop over all buckets in the cache store.
|
protected boolean |
BucketBasedCacheStore.removeLockSafe(Object key,
Integer lockingKey)
Removes an entry from a Bucket, locating the relevant Bucket using the key's hash code.
|
protected void |
BucketBasedCacheStore.storeLockSafe(InternalCacheEntry entry,
Integer lockingKey)
Stores an entry in an appropriate Bucket, based on the key's hash code.
|
protected abstract void |
BucketBasedCacheStore.updateBucket(Bucket bucket)
Updates a bucket in the store with the Bucket passed in to the method.
|
Modifier and Type | Method and Description |
---|---|
Set<InternalCacheEntry> |
ClusterCacheLoader.load(int maxElems) |
InternalCacheEntry |
ClusterCacheLoader.load(Object key) |
Set<InternalCacheEntry> |
ClusterCacheLoader.loadAll() |
Set<Object> |
ClusterCacheLoader.loadAllKeys(Set<Object> keysToExclude) |
void |
ClusterCacheLoader.start() |
void |
ClusterCacheLoader.stop() |
Modifier and Type | Method and Description |
---|---|
protected void |
AsyncStore.applyModificationsSync(ConcurrentMap<Object,Modification> mods) |
void |
ChainingCacheStore.clear() |
void |
AbstractDelegatingStore.clear() |
void |
SingletonStore.clear() |
void |
ChainingCacheStore.commit(GlobalTransaction tx) |
void |
AbstractDelegatingStore.commit(GlobalTransaction tx) |
void |
AsyncStore.commit(GlobalTransaction tx) |
void |
SingletonStore.commit(GlobalTransaction tx) |
boolean |
ChainingCacheStore.containsKey(Object key) |
boolean |
AbstractDelegatingStore.containsKey(Object key) |
void |
ChainingCacheStore.fromStream(ObjectInput inputStream) |
void |
AbstractDelegatingStore.fromStream(ObjectInput inputStream) |
void |
SingletonStore.fromStream(ObjectInput inputStream) |
void |
AbstractDelegatingStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AsyncStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
ChainingCacheStore.init(CacheLoaderConfig config,
Cache cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
ChainingCacheStore.load(int numEntries) |
Set<InternalCacheEntry> |
AbstractDelegatingStore.load(int numEntries) |
InternalCacheEntry |
ChainingCacheStore.load(Object key) |
InternalCacheEntry |
AbstractDelegatingStore.load(Object key) |
Set<InternalCacheEntry> |
ChainingCacheStore.loadAll() |
Set<InternalCacheEntry> |
AbstractDelegatingStore.loadAll() |
Set<Object> |
ChainingCacheStore.loadAllKeys(Set<Object> keysToExclude) |
Set<Object> |
AbstractDelegatingStore.loadAllKeys(Set<Object> keysToExclude) |
void |
ChainingCacheStore.prepare(List<? extends Modification> list,
GlobalTransaction tx,
boolean isOnePhase) |
void |
AbstractDelegatingStore.prepare(List<? extends Modification> list,
GlobalTransaction tx,
boolean isOnePhase) |
void |
AsyncStore.prepare(List<? extends Modification> mods,
GlobalTransaction tx,
boolean isOnePhase) |
void |
SingletonStore.prepare(List<? extends Modification> list,
GlobalTransaction tx,
boolean isOnePhase) |
void |
ChainingCacheStore.purgeExpired() |
void |
AbstractDelegatingStore.purgeExpired() |
void |
SingletonStore.purgeExpired() |
void |
ChainingCacheStore.purgeIfNecessary() |
boolean |
ChainingCacheStore.remove(Object key) |
boolean |
AbstractDelegatingStore.remove(Object key) |
boolean |
SingletonStore.remove(Object key) |
void |
ChainingCacheStore.removeAll(Set<Object> keys) |
void |
AbstractDelegatingStore.removeAll(Set<Object> keys) |
void |
ChainingCacheStore.start() |
void |
AbstractDelegatingStore.start() |
void |
AsyncStore.start() |
void |
SingletonStore.start() |
void |
ChainingCacheStore.stop() |
void |
AbstractDelegatingStore.stop() |
void |
AsyncStore.stop() |
void |
SingletonStore.stop() |
void |
ChainingCacheStore.store(InternalCacheEntry ed) |
void |
AbstractDelegatingStore.store(InternalCacheEntry ed) |
void |
SingletonStore.store(InternalCacheEntry ed) |
void |
ChainingCacheStore.toStream(ObjectOutput outputStream) |
void |
AbstractDelegatingStore.toStream(ObjectOutput outputStream) |
Modifier and Type | Method and Description |
---|---|
protected void |
FileCacheStore.clearLockSafe() |
protected void |
FileCacheStore.fromStreamLockSafe(ObjectInput objectInput) |
void |
FileCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
protected Bucket |
FileCacheStore.loadBucket(File bucketFile) |
protected Bucket |
FileCacheStore.loadBucket(Integer hash) |
Bucket |
FileCacheStore.loadBucketContainingKey(String key) |
protected void |
FileCacheStore.loopOverBuckets(BucketBasedCacheStore.BucketHandler handler) |
protected void |
FileCacheStore.purgeInternal() |
void |
FileCacheStore.start() |
void |
FileCacheStore.stop() |
protected void |
FileCacheStore.toStreamLockSafe(ObjectOutput objectOutput) |
void |
FileCacheStore.updateBucket(Bucket b) |
Modifier and Type | Method and Description |
---|---|
void |
DataManipulationHelper.clear() |
void |
TableManipulation.createTable(Connection conn) |
void |
TableManipulation.dropTable(Connection conn) |
protected abstract boolean |
DataManipulationHelper.fromStreamProcess(Object objFromStream,
PreparedStatement ps,
ObjectInput objectInput) |
void |
DataManipulationHelper.fromStreamSupport(ObjectInput objectInput) |
protected abstract void |
DataManipulationHelper.loadAllKeysProcess(ResultSet rs,
Set<Object> keys,
Set<Object> keysToExclude) |
Set<Object> |
DataManipulationHelper.loadAllKeysSupport(Set<Object> keysToExclude) |
protected abstract void |
DataManipulationHelper.loadAllProcess(ResultSet rs,
Set<InternalCacheEntry> result) |
protected abstract void |
DataManipulationHelper.loadAllProcess(ResultSet rs,
Set<InternalCacheEntry> result,
int maxEntries) |
Set<InternalCacheEntry> |
DataManipulationHelper.loadAllSupport(boolean filterExpired) |
Set<InternalCacheEntry> |
DataManipulationHelper.loadSome(int maxEntries) |
static ByteBuffer |
JdbcUtil.marshall(StreamingMarshaller marshaller,
Object bucket) |
void |
TableManipulation.start(ConnectionFactory connectionFactory) |
void |
TableManipulation.stop() |
boolean |
TableManipulation.tableExists(Connection connection) |
boolean |
TableManipulation.tableExists(Connection connection,
String tableName) |
protected abstract void |
DataManipulationHelper.toStreamProcess(ResultSet rs,
InputStream is,
ObjectOutput objectOutput) |
void |
DataManipulationHelper.toStreamSupport(ObjectOutput objectOutput,
byte streamDelimiter,
boolean filterExpired) |
static Object |
JdbcUtil.unmarshall(StreamingMarshaller marshaller,
InputStream inputStream) |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcBinaryCacheStore.clearLockSafe() |
void |
JdbcBinaryCacheStore.doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
Keeps a reference to the connection factory for further use.
|
protected void |
JdbcBinaryCacheStore.fromStreamLockSafe(ObjectInput objectInput) |
void |
JdbcBinaryCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
protected void |
JdbcBinaryCacheStore.insertBucket(Bucket bucket) |
Set<Object> |
JdbcBinaryCacheStore.loadAllKeys(Set<Object> keysToExclude) |
Set<InternalCacheEntry> |
JdbcBinaryCacheStore.loadAllLockSafe() |
protected Bucket |
JdbcBinaryCacheStore.loadBucket(Integer keyHashCode) |
protected Set<InternalCacheEntry> |
JdbcBinaryCacheStore.loadLockSafe(int maxEntries) |
protected void |
JdbcBinaryCacheStore.loopOverBuckets(BucketBasedCacheStore.BucketHandler handler) |
void |
JdbcBinaryCacheStore.purgeInternal() |
void |
JdbcBinaryCacheStore.start() |
void |
JdbcBinaryCacheStore.stop() |
protected void |
JdbcBinaryCacheStore.toStreamLockSafe(ObjectOutput objectOutput) |
protected void |
JdbcBinaryCacheStore.updateBucket(Bucket bucket) |
Modifier and Type | Method and Description |
---|---|
Connection |
PooledConnectionFactory.getConnection() |
Connection |
SimpleConnectionFactory.getConnection() |
Connection |
ManagedConnectionFactory.getConnection() |
abstract Connection |
ConnectionFactory.getConnection()
Fetches a connection from the factory.
|
static ConnectionFactory |
ConnectionFactory.getConnectionFactory(String connectionFactoryClass,
ClassLoader classLoader)
Constructs a
ConnectionFactory based on the supplied class
name. |
void |
PooledConnectionFactory.start(ConnectionFactoryConfig config,
ClassLoader classLoader) |
void |
SimpleConnectionFactory.start(ConnectionFactoryConfig config,
ClassLoader classLoader) |
void |
ManagedConnectionFactory.start(ConnectionFactoryConfig config,
ClassLoader classLoader) |
abstract void |
ConnectionFactory.start(ConnectionFactoryConfig config,
ClassLoader classLoader)
Starts the connection factory.
|
Modifier and Type | Method and Description |
---|---|
void |
JdbcMixedCacheStore.clear() |
void |
JdbcMixedCacheStore.fromStream(ObjectInput inputStream) |
void |
JdbcMixedCacheStore.init(CacheLoaderConfig config,
Cache cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
JdbcMixedCacheStore.load(int numEntries) |
InternalCacheEntry |
JdbcMixedCacheStore.load(Object key) |
Set<InternalCacheEntry> |
JdbcMixedCacheStore.loadAll() |
Set<Object> |
JdbcMixedCacheStore.loadAllKeys(Set<Object> keysToExclude) |
protected void |
JdbcMixedCacheStore.purgeInternal() |
boolean |
JdbcMixedCacheStore.remove(Object key) |
void |
JdbcMixedCacheStore.start() |
void |
JdbcMixedCacheStore.stop() |
void |
JdbcMixedCacheStore.store(InternalCacheEntry ed) |
void |
JdbcMixedCacheStore.toStream(ObjectOutput outputStream) |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcStringBasedCacheStore.clearLockSafe() |
void |
JdbcStringBasedCacheStore.doConnectionFactoryInitialization(ConnectionFactory connectionFactory)
Keeps a reference to the connection factory for further use.
|
void |
JdbcStringBasedCacheStore.fromStreamLockSafe(ObjectInput objectInput) |
protected String |
JdbcStringBasedCacheStore.getLockFromKey(Object key) |
void |
JdbcStringBasedCacheStore.init(CacheLoaderConfig config,
Cache cache,
StreamingMarshaller m) |
protected Set<Object> |
JdbcStringBasedCacheStore.loadAllKeysLockSafe(Set<Object> keysToExclude) |
protected Set<InternalCacheEntry> |
JdbcStringBasedCacheStore.loadAllLockSafe() |
protected Set<InternalCacheEntry> |
JdbcStringBasedCacheStore.loadLockSafe(int maxEntries) |
protected InternalCacheEntry |
JdbcStringBasedCacheStore.loadLockSafe(Object key,
String lockingKey) |
void |
JdbcStringBasedCacheStore.purgeInternal() |
boolean |
JdbcStringBasedCacheStore.removeLockSafe(Object key,
String keyStr) |
void |
JdbcStringBasedCacheStore.start() |
void |
JdbcStringBasedCacheStore.stop() |
void |
JdbcStringBasedCacheStore.storeLockSafe(InternalCacheEntry ed,
String lockingKey) |
protected void |
JdbcStringBasedCacheStore.toStreamLockSafe(ObjectOutput objectOutput) |
Modifier and Type | Class and Description |
---|---|
class |
UnsupportedKeyTypeException
Exception thrown by certain cache stores when one tries to persist an entry with an unsupported key type.
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteCacheStore.clear() |
boolean |
RemoteCacheStore.containsKey(Object key) |
void |
RemoteCacheStore.fromStream(ObjectInput inputStream) |
void |
RemoteCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
RemoteCacheStore.load(int numEntries) |
InternalCacheEntry |
RemoteCacheStore.load(Object key) |
Set<InternalCacheEntry> |
RemoteCacheStore.loadAll() |
Set<Object> |
RemoteCacheStore.loadAllKeys(Set<Object> keysToExclude) |
protected void |
RemoteCacheStore.purgeInternal() |
boolean |
RemoteCacheStore.remove(Object key) |
void |
RemoteCacheStore.start() |
void |
RemoteCacheStore.stop() |
void |
RemoteCacheStore.store(InternalCacheEntry entry) |
void |
RemoteCacheStore.toStream(ObjectOutput outputStream) |
Modifier and Type | Method and Description |
---|---|
void |
Log.errorClearinAsyncStore(CacheLoaderException e) |
void |
Log.errorPurgingAsyncStore(CacheLoaderException e) |
void |
Log.problemsPurgingFile(File buckedFile,
CacheLoaderException e) |
void |
Log.unableToLoadFromCacheLoader(Object key,
CacheLoaderException cle) |
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.