Package | Description |
---|---|
org.infinispan.eviction |
Classes related to eviction.
|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.loaders |
This package contains loaders and stores, which are used for overflow or persistence.
|
org.infinispan.loaders.bdbje |
This package contains a
CacheStore implementation based on
Oracle's BDBJE storage engine. |
org.infinispan.loaders.bucket |
Abstract classes that use hashed buckets to store entries.
|
org.infinispan.loaders.cassandra |
This package contains a
CacheStore implementation based on
persisting to Apache Cassandra |
org.infinispan.loaders.cloud |
This package contains a
CacheStore implementation based on
JClouds, which in turn is an abstraction layer to store data on cloud infrastructure providers
such as Amazon's S3,
RackspaceCloud's CloudFiles,
Microsoft's Windows Azure Blob Storage API, and others. |
org.infinispan.loaders.cloud.logging | |
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.hbase |
This package contains a
CacheStore implementation based on
persisting to HBase. |
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.jdbm |
This package contains a
CacheStore implementation based on
persisting to JDBM. |
org.infinispan.loaders.keymappers | |
org.infinispan.loaders.leveldb | |
org.infinispan.loaders.remote | |
org.infinispan.loaders.remote.logging | |
org.infinispan.loaders.remote.wrapper | |
org.infinispan.lucene.cachestore | |
org.infinispan.lucene.logging | |
org.infinispan.nearcache.jms | |
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 |
CacheStoreInterceptor.clearCacheStore() |
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 |
AbstractCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
LockSupportCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AbstractCacheLoader.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 |
AbstractCacheStore.start() |
void |
LockSupportCacheStore.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 |
---|---|
protected void |
BdbjeCacheStore.applyModifications(List<? extends Modification> mods)
Perform the
mods atomically by creating a worker and invoking
them in TransactionRunner.run(com.sleepycat.collections.TransactionWorker) . |
void |
BdbjeCacheStore.clear()
Clears all entries in the store
|
void |
BdbjeCacheStore.commit(GlobalTransaction tx)
Commits a transaction that has been previously prepared.
|
protected void |
BdbjeCacheStore.completeTransaction(GlobalTransaction tx,
boolean commit)
Looks up the SleepyCat transaction associated with the parameter
tx . |
void |
BdbjeCacheStore.fromStream(ObjectInput ois)
Writes contents of the stream to the store.
|
void |
BdbjeCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m)
Used to initialize a cache loader.
|
Set<InternalCacheEntry> |
BdbjeCacheStore.load(int numEntries) |
InternalCacheEntry |
BdbjeCacheStore.load(Object key)
Loads an entry mapped to by a given key.
|
Set<InternalCacheEntry> |
BdbjeCacheStore.loadAll()
Loads all entries in the loader.
|
Set<Object> |
BdbjeCacheStore.loadAllKeys(Set<Object> keysToExclude) |
protected void |
BdbjeCacheStore.prepare(List<? extends Modification> mods,
GlobalTransaction tx)
Looks up the
SleepyCat transaction associated with tx . |
void |
BdbjeCacheStore.prepare(List<? extends Modification> mods,
GlobalTransaction tx,
boolean isOnePhase)
Issues a prepare call with a set of modifications to be applied to the cache store
|
protected void |
BdbjeCacheStore.purgeInternal()
Iterate through
StoredMap.entrySet() and remove, if expired. |
Properties |
BdbjeCacheStoreConfig.readEnvironmentProperties() |
boolean |
BdbjeCacheStore.remove(Object key)
Removes an entry in the store.
|
void |
BdbjeCacheStore.start()
Validates configuration, configures and opens the
Environment , then opens the databases . |
void |
BdbjeCacheStore.stop()
Stops transaction and purge processing and closes the SleepyCat environment.
|
void |
BdbjeCacheStore.store(InternalCacheEntry ed)
Stores an entry
|
void |
BdbjeCacheStore.toStream(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 |
---|---|
void |
CassandraCacheStore.clear() |
void |
CassandraCacheStore.fromStream(ObjectInput in)
Reads from a stream the number of entries (long) then the entries themselves.
|
void |
CassandraCacheStore.init(CacheLoaderConfig clc,
Cache<?,?> cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
CassandraCacheStore.load(int numEntries) |
InternalCacheEntry |
CassandraCacheStore.load(Object key) |
Set<InternalCacheEntry> |
CassandraCacheStore.loadAll() |
Set<Object> |
CassandraCacheStore.loadAllKeys(Set<Object> keysToExclude) |
protected void |
CassandraCacheStore.purgeInternal()
Purge expired entries.
|
boolean |
CassandraCacheStore.remove(Object key) |
void |
CassandraCacheStore.start() |
void |
CassandraCacheStore.stop()
Closes all databases, ignoring exceptions, and nulls references to all database related
information.
|
void |
CassandraCacheStore.store(InternalCacheEntry entry) |
void |
CassandraCacheStore.toStream(ObjectOutput out)
Writes to a stream the number of entries (long) then the entries themselves.
|
Modifier and Type | Method and Description |
---|---|
void |
CloudCacheStore.applyModifications(List<? extends Modification> modifications) |
protected void |
CloudCacheStore.fromStreamLockSafe(ObjectInput objectInput) |
void |
CloudCacheStore.init(CacheLoaderConfig cfg,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
CloudCacheStore.init(CacheLoaderConfig cfg,
Cache<?,?> cache,
StreamingMarshaller m,
org.jclouds.blobstore.BlobStoreContext ctx,
org.jclouds.blobstore.BlobStore blobStore,
org.jclouds.blobstore.AsyncBlobStore asyncBlobStore,
boolean constructInternalBlobstores) |
protected Bucket |
CloudCacheStore.loadBucket(Integer hash) |
protected void |
CloudCacheStore.loopOverBuckets(BucketBasedCacheStore.BucketHandler handler) |
protected void |
CloudCacheStore.purgeInternal() |
void |
CloudCacheStore.start() |
protected void |
CloudCacheStore.toStreamLockSafe(ObjectOutput objectOutput) |
protected void |
CloudCacheStore.updateBucket(Bucket bucket) |
Modifier and Type | Method and Description |
---|---|
void |
Log.unableToReadBlob(String blobName,
CacheLoaderException e) |
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(List<Modification> mods) |
void |
ChainingCacheStore.clear() |
void |
AbstractDelegatingStore.clear() |
void |
SingletonStore.clear() |
void |
ChainingCacheStore.commit(GlobalTransaction tx) |
void |
AsyncStore.commit(GlobalTransaction tx) |
void |
AbstractDelegatingStore.commit(GlobalTransaction tx) |
void |
SingletonStore.commit(GlobalTransaction tx) |
boolean |
ChainingCacheStore.containsKey(Object key) |
boolean |
AsyncStore.containsKey(Object key) |
boolean |
AbstractDelegatingStore.containsKey(Object key) |
void |
ChainingCacheStore.fromStream(ObjectInput inputStream) |
void |
AbstractDelegatingStore.fromStream(ObjectInput inputStream) |
void |
SingletonStore.fromStream(ObjectInput inputStream) |
void |
ChainingCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AsyncStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
void |
AbstractDelegatingStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
ChainingCacheStore.load(int numEntries) |
Set<InternalCacheEntry> |
AsyncStore.load(int numEntries) |
Set<InternalCacheEntry> |
AbstractDelegatingStore.load(int numEntries) |
InternalCacheEntry |
ChainingCacheStore.load(Object key) |
InternalCacheEntry |
AsyncStore.load(Object key) |
InternalCacheEntry |
AbstractDelegatingStore.load(Object key) |
Set<InternalCacheEntry> |
ChainingCacheStore.loadAll() |
Set<InternalCacheEntry> |
AsyncStore.loadAll() |
Set<InternalCacheEntry> |
AbstractDelegatingStore.loadAll() |
Set<Object> |
ChainingCacheStore.loadAllKeys(Set<Object> keysToExclude) |
Set<Object> |
AsyncStore.loadAllKeys(Set<Object> keysToExclude) |
Set<Object> |
AbstractDelegatingStore.loadAllKeys(Set<Object> keysToExclude) |
void |
ChainingCacheStore.prepare(List<? extends Modification> list,
GlobalTransaction tx,
boolean isOnePhase) |
void |
AsyncStore.prepare(List<? extends Modification> mods,
GlobalTransaction tx,
boolean isOnePhase) |
void |
AbstractDelegatingStore.prepare(List<? extends Modification> list,
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 |
AsyncStore.removeAll(Set<Object> keys) |
void |
AbstractDelegatingStore.removeAll(Set<Object> keys) |
void |
ChainingCacheStore.start() |
void |
AsyncStore.start() |
void |
AbstractDelegatingStore.start() |
void |
SingletonStore.start() |
void |
ChainingCacheStore.stop() |
void |
AsyncStore.stop() |
void |
AbstractDelegatingStore.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 |
HBaseCacheStore.clear()
Removes all entries from the cache.
|
void |
HBaseCacheStore.fromStream(ObjectInput in)
Stores an object that has been unmarshalled to a stream into the cache.
|
void |
HBaseCacheStore.init(CacheLoaderConfig clc,
Cache<?,?> cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
HBaseCacheStore.load(int numEntries)
Loads entries from the cache up to a certain number.
|
InternalCacheEntry |
HBaseCacheStore.load(Object key)
Loads an entry from the cache, given its key.
|
Set<InternalCacheEntry> |
HBaseCacheStore.loadAll()
Loads all entries from the cache.
|
Set<Object> |
HBaseCacheStore.loadAllKeys(Set<Object> keysToExclude)
Loads all keys from the cache, optionally excluding some.
|
protected void |
HBaseCacheStore.purgeInternal()
Purges any expired entries from the cache.
|
boolean |
HBaseCacheStore.remove(Object key)
Removes an entry from the cache, given its key.
|
void |
HBaseCacheStore.start() |
void |
HBaseCacheStore.store(InternalCacheEntry entry)
Stores an entry into the cache.
|
void |
HBaseCacheStore.toStream(ObjectOutput out)
Loads all entries from the cache and marshalls them to an object stream.
|
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 |
ManagedConnectionFactory.getConnection() |
Connection |
PooledConnectionFactory.getConnection() |
Connection |
SimpleConnectionFactory.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 |
ManagedConnectionFactory.start(ConnectionFactoryConfig config,
ClassLoader classLoader) |
void |
PooledConnectionFactory.start(ConnectionFactoryConfig config,
ClassLoader classLoader) |
void |
SimpleConnectionFactory.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 | Method and Description |
---|---|
protected void |
JdbmCacheStore.applyModifications(List<? extends Modification> mods) |
void |
JdbmCacheStore.clear() |
void |
JdbmCacheStore.fromStream(ObjectInput in)
Reads from a stream the number of entries (long) then the entries themselves.
|
void |
JdbmCacheStore.init(CacheLoaderConfig clc,
Cache<?,?> cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
JdbmCacheStore.load(int numEntries) |
InternalCacheEntry |
JdbmCacheStore.load(Object key) |
Set<InternalCacheEntry> |
JdbmCacheStore.loadAll() |
Set<Object> |
JdbmCacheStore.loadAllKeys(Set<Object> keysToExclude) |
protected void |
JdbmCacheStore.purgeInternal()
Purge expired entries.
|
boolean |
JdbmCacheStore.remove(Object key) |
boolean |
JdbmCacheStore.remove0(Object key) |
void |
JdbmCacheStore.start() |
void |
JdbmCacheStore.stop()
Closes all databases, ignoring exceptions, and nulls references to all database related information.
|
void |
JdbmCacheStore.store(InternalCacheEntry entry) |
void |
JdbmCacheStore.toStream(ObjectOutput out)
Writes to a stream the number of entries (long) then the entries themselves.
|
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 |
---|---|
protected void |
LevelDBCacheStore.clearLockSafe() |
protected void |
LevelDBCacheStore.fromStreamLockSafe(ObjectInput ois) |
protected Integer |
LevelDBCacheStore.getLockFromKey(Object key) |
void |
LevelDBCacheStore.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
protected Set<Object> |
LevelDBCacheStore.loadAllKeysLockSafe(Set<Object> keysToExclude) |
protected Set<InternalCacheEntry> |
LevelDBCacheStore.loadAllLockSafe() |
protected Set<InternalCacheEntry> |
LevelDBCacheStore.loadLockSafe(int maxEntries) |
protected InternalCacheEntry |
LevelDBCacheStore.loadLockSafe(Object key,
Integer lockingKey) |
protected void |
LevelDBCacheStore.purgeInternal() |
protected boolean |
LevelDBCacheStore.removeLockSafe(Object key,
Integer lockingKey) |
void |
LevelDBCacheStore.start() |
void |
LevelDBCacheStore.stop() |
protected void |
LevelDBCacheStore.storeLockSafe(InternalCacheEntry ed,
Integer lockingKey) |
protected void |
LevelDBCacheStore.toStreamLockSafe(ObjectOutput oos) |
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 |
---|---|
CacheLoaderException |
Log.unsupportedKeyFormat(String name) |
CacheLoaderException |
Log.unsupportedValueFormat(String name) |
Modifier and Type | Method and Description |
---|---|
ByteArrayKey |
HotRodEntryWrapper.wrapKey(Object key) |
K |
EntryWrapper.wrapKey(Object key) |
org.infinispan.server.core.CacheValue |
HotRodEntryWrapper.wrapValue(MetadataValue<?> value) |
V |
EntryWrapper.wrapValue(MetadataValue<?> value) |
Modifier and Type | Method and Description |
---|---|
boolean |
LuceneCacheLoader.containsKey(Object key) |
void |
LuceneCacheLoader.init(CacheLoaderConfig config,
Cache<?,?> cache,
StreamingMarshaller m) |
Set<InternalCacheEntry> |
LuceneCacheLoader.load(int maxEntries)
Loads up to a specific number of entries.
|
InternalCacheEntry |
LuceneCacheLoader.load(Object key) |
Set<InternalCacheEntry> |
LuceneCacheLoader.loadAll() |
Set<Object> |
LuceneCacheLoader.loadAllKeys(Set keysToExclude) |
void |
LuceneCacheLoader.start() |
void |
LuceneCacheLoader.stop() |
Modifier and Type | Method and Description |
---|---|
CacheLoaderException |
Log.exceptionInCacheLoader(Exception e) |
Modifier and Type | Method and Description |
---|---|
void |
Log.couldNotWalkDirectory(String name,
CacheLoaderException e) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteEventCacheStore.start() |
void |
RemoteEventCacheStore.stop() |
Modifier and Type | Method and Description |
---|---|
void |
Log.problemsPurgingFile(File buckedFile,
CacheLoaderException e) |
void |
Log.unableToLoadFromCacheLoader(Object key,
CacheLoaderException cle) |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.