|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
CacheLoader that holds common implementations for some methodsCacheStore that holds common implementations for some methodsAbstractCacheStore.AbstractDelegatingCache, but for AdvancedCache.CacheManagerNotifierImpl and
CacheNotifierImplModuleLifecycle interface, designed for easy
extension.AbstractConfigurationBean
.GlobalTransactionTxInvocationContext.Fqn under the current node.
AbstractComponentRegistry.Component.injectionMethods.
Cache.mods atomically by creating a worker and invoking
them in TransactionRunner.run(com.sleepycat.collections.TransactionWorker).
AtomicHashMap to provide reader consistencyCache.startBatch() and
Cache.endBatch(boolean) calls.CacheStore.BdbjeCacheStore.LinkedHashMap except that this version makes use of the fact that entries are
bidirectionally linked and can hence be navigated either from the start or from the end.Executors except that the factory methods here allow you to specify the
size of the blocking queue that backs the executor.RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean) except that the task
is passed to the transport executor and a Future is returned.
RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean) except that
the task is passed to the transport executor and a Future is returned.
CacheEntryActivated.CacheEntryCreated.CacheEntryEvicted.CacheLoader.CacheEntryLoaded.CacheEntryModified
The CacheEntryModifiedEvent.getValue() method's behavior is specific to whether the callback is triggered before or after the event
in question.CacheEntryPassivated.CacheEntryRemoved.CacheEntryVisited.Cache fail unexpectedly.Configuration.isExposeJmxStatistics() is true, then class will register all the MBeans from cache local's
ConfigurationRegistry to the MBean server.CacheLoader implementation if there are problems reading from a loader.Cache instance, and is often
used as a starting point to using the Cache.QueryFactory.RpcManager only replicates commands wrapped in a CacheRpcCommand.CacheStarted.CacheStopped.CacheLoader interface that can be written to.CacheStore.clear() modificationMap.clear().
CloudCacheStore.ClusterCacheLoader.ClusteredGetCommands.ReplicableCommands.Visitor interface allowing it to
intercept invocations on VisitableCommands.DeltaAware.delta()) and can be
discarded.
FqnComparator.
tx.
ConcurrentHashMap to deal with the fact that the
JDK does not have a proper concurrent Set implementation that uses efficient lock striping.Configurations.ConnectionFactory.CacheLoader.load(Object), to ensure that a response is
returned only if the entry is not expired.
JdbmCacheStoreConfig.setComparatorClassName(String).
TxInvocationContext.
NonTxInvocationContext with the NonTxInvocationContext.isOriginLocal()
returning true.
NonTxInvocationContext whose NonTxInvocationContext.isOriginLocal() flag will be true.
RemoteTransaction based on the supplied params.
RemoteTransaction with no modifications.
RemoteTxInvocationContext.
StoredMap persisted by the database
StoredMap persisted by the database
Cache as a parameter
LocalTxInvocationContext.
JdbcStringBasedCacheStore
and JdbcBinaryCacheStore.DeadlockDetectingGlobalTransaction with
appropriate information needed in order to accomplish deadlock detection.Version.getVersionShort().
Cache instance, and is often used as a
starting point to using the Cache.Key2StringMapper.DeltaAware implementation.Modification objects and
executes it against the CacheStore. Current commands supported are: STORE CLEAR
REMOVE PURGE_EXPIRED
TransactionLogger.drain() except that relevant locks are acquired so that no more commands are added to the
transaction log during this process, and transaction logging is disabled after draining.
DummyTransactionManager.Configuration as being modifiable even after the cache has started.Cache.startBatch().
MVCCEntry instances for use in the InvocationContext.Set view of the mappings contained in this map.
SimpleDataContainer, this implementation always forces the
collection of creation timestamps for entries.BucketBasedCacheStore.FileCacheStore.Flag.Node in a TreeCache.Node.
null if this map contains no mapping for the
key.
null if this map contains
no mapping for the key.
clone of the Configuration registered under the given name.
CacheLoaderConfig type.
CacheLoaderConfig type.
ConnectionFactory based on the supplied class
name.
DefaultConsistentHash, or an instance of
UnionConsistentHash if a rehash is in progress.
RpcManager.retrieveState(String, long) has been invoked and hasn't yet returned (i.e., a state transfer is in
progress), this method will return the current Address from which a state transfer is being attempted.
CustomInterceptorConfig, if any, associated with this configuration
object.
Node.
DistributionManager if the cache is configured
to use Distribution.
Fqn which represents the location of this Node in the cache structure.
Configuration
InvocationContext that is currently associated with the calling thread.
Set containing the data in this Node.
Map.get(Object) and
Map.containsKey(Object) operationsFqn.SEPARATOR.
BucketBasedCacheStores the lock should be acquired at bucket level.
DefaultFactoryFor annotation that is capable of creating the component
class).
TransactionXaAdapter corresponding to the supplied transaction.
CacheQuery
RemoteTransaction associated with the supplied transaction id.
Fqn passed in exists.
LockSupportCacheStore.lockForWriting(String), but with 0 timeout.
ImmortalCacheEntryMap.Entry} with an immutable Map.Entry}.
InternalCacheEntry} with an immutable InternalCacheEntry}.
Listenable.addListener(Object) API.CacheQueryImpl and EagerIterator
Simply an abstraction for one method to reduce unnecessary code replication.DirectoryDirectoryUnionConsistentHash
ReplicableCommand read from a data stream with components specific
to the target cache instance.
InvocationContext and the calling thread.InvocationContextContainer.AccessibleObject.setAccessible(boolean)
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean)
except that the task is passed to the transport executor and a Future is returned.
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean)
except that the task is passed to the transport executor and a Future is returned.
RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand,
boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout.
DeadlockDetectingGlobalTransaction.interruptProcessingThread() will be ignored.
QueryIterator with a given integer parameter - the fetchSize.
QueryIterator.
TransactionManager instance from "java:/TransactionManager".BucketBasedCacheStore implementation that will store all the buckets as rows in database, each row
corresponding to a bucket.JdbcBinaryCacheStore.JdbcBinaryCacheStore and JdbcStringBasedCacheStore.JdbcMixedCacheStore.CacheStore implementation that stores the entries in a database.JdbcStringBasedCacheStore cache store.CacheLoader based on the JDBM project.JdbmCacheStore.Marshaller of the cache.ResponseFilter.Set view of the keys contained in this map.
QueryIterator with a given integer parameter - the
fetchSize.
CacheQuery.lazyIterator(int fetchSize) method but passes in a default 1 as a parameter.
QueryIterator.null (i.e.
ConsistentHash.locate(Object, int) multiple times for each key in the collection of
keys.
LockManager.AbstractCacheStore adding lock support for consistently accessing stored data.LockSupportCacheStore.Log instances.FileLookup.
FIFODataContainer, this implementation
additionally unlinks and re-links entries at the tail whenever entries are visited (using a get()) or are updated (a
put() on an existing key).SimpleDataContainer, this implementation always forces the
collection of last used timestamps for entries.InfinispanDirectoryMarshalledValues.DeltaAware instance, and return a coherent and complete
DeltaAware instance.
CacheStore modificationModifications to be performed atomically via TransactionRunner.Modifications that will be applied to the supplied CacheStore
ModuleProperties class represents Infinispan's module configuration key value
pairs.MortalCacheEntryComponentName annotation on the classes requested in Inject annotated methods.ResponseFilter.isAcceptable(Response, Address), this method is called to see whether we are done
with the request and can unblock the caller
named logical grouping of data in the TreeCache API of JBoss Cache.AtomicMapNotifyingFuture.ObjectInput
ByteBuffer, which allows direct access to the byte
array with minimal array copying
ObjectOutput
AtomicMap interfaces and API that Infinispan exposes as building
blocks in creating other public interfaces such as the Tree API.Cache.startBatch() and Cache.endBatch(boolean)
API.CacheManager and its various Caches, and related
utilities.CacheStore implementation based on
Oracle's BDBJE storage engine.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.CacheLoader (not CacheStore) that polls other nodes in the cluster for state.CacheStore implementation.CacheStore implementation based on
a JDBC database connection.CacheStore implementation based on
persisting to JDBM.CacheStore.Cache-specific notifications and eventing.CacheManager-specific notifications and eventing.TransactionManagers.OwnableReentrantLocks.org.infinispan.config.GlobalConfiguration#getDefaultConfiguration()
This is typically used to configure a DefaultCacheManager
DataContainer.get(Object)}
except that it does not update or reorder any of the internal constructs.
MBeanServerLookup, will return the platform MBean server.TransactionRunner, which allows us to prepare a transaction without committing it. The
transaction prepared is accessible via CurrentTransaction.getTransaction()superclass and caches a current reference to CurrentTransaction.
superclass and caches
a current reference to CurrentTransaction.
SleepyCat transaction associated with tx.
run, except that the
transaction is not committed on success.
StoredMap.entrySet() and remove, if expired.
Map.put(Object, Object), which takes in lifespan parameters.
Map.put(Object, Object), which takes in lifespan parameters.
Node in this cache.
Node.
Map.putAll(Map), which takes in lifespan parameters.
Map.putAll(Map), which takes in lifespan parameters.
Map.putAll(Map).
Cache.putAll(Map, long, TimeUnit).
Cache.putAll(Map, long, TimeUnit, long, TimeUnit).
Map.put(Object, Object).
Cache.put(Object, Object, long, TimeUnit) .
Cache.put(Object, Object, long, TimeUnit, long, TimeUnit).
ConcurrentMap.putIfAbsent(Object, Object), which takes in lifespan parameters.
ConcurrentMap.putIfAbsent(Object, Object), which takes in lifespan parameters.
ConcurrentMap.putIfAbsent(Object, Object).
Cache.putIfAbsent(Object, Object, long, TimeUnit) .
Cache.putIfAbsent(Object, Object, long, TimeUnit, long, TimeUnit).
Map.put(Object, Object)CacheQueryXmlConfigHelper.readStringContents(org.w3c.dom.Element,String) except that it returns a boolean.
XmlConfigHelper.readStringContents(org.w3c.dom.Element,String) except that it returns a boolean.
ImmutableListCopy.writeExternal(java.io.ObjectOutput) for serialization format
CacheLoader, i.e., suppressing all write
methods.AbstractQueuedSynchronizer.Synchronization callback with this transaction.
ReplicableCommands from a byte stream.CacheStore.remove(Object) modificationMap.remove(Object).
ConcurrentMap.remove(Object, Object).
Fqn.
TransactionXaAdapter corresponding to the given tx.
Node indicated by absolute Fqn.
RemoteTransaction corresponding to the given tx.
ReadCommittedEntry that provides Repeatable Read semanticsConcurrentMap.replace(Object, Object), which takes in lifespan parameters.
ConcurrentMap.replace(Object, Object, Object), which takes in lifespan parameters.
ConcurrentMap.replace(Object, Object), which takes in lifespan parameters.
ConcurrentMap.replace(Object, Object, Object), which takes in lifespan parameters.
Node.putAll(java.util.Map) except that it removes any entries that exists in the data map first.
ConcurrentMap.replace(Object, Object).
Cache.replace(Object, Object, long, TimeUnit).
Cache.replace(Object, Object, long, TimeUnit, long, TimeUnit).
ConcurrentMap.replace(Object, Object, Object).
Cache.replace(Object, Object, Object, long, TimeUnit).
Cache.replace(Object, Object, Object, long, TimeUnit, long, TimeUnit).
InvocationContext with the calling thread.
InboundInvocationHandler.generateState(String, java.io.OutputStream)), and applies this
state to the current cache via the InboundInvocationHandler.applyState(String, java.io.InputStream)
callback.
ReversibleOrderedSet.reverseIterator() method.CacheStore.prepare(java.util.List, org.infinispan.transaction.xa.GlobalTransaction, boolean).
CacheStore.prepare(java.util.List, org.infinispan.transaction.xa.GlobalTransaction, boolean).
Transport.Transport implementation,
and is used to set up the transport and provide lifecycle and dependency hooks into external transport
implementations.SearchConfiguration so that within Infinispan-Query, there is
no need for a Hibernate Core configuration object.ConnectionFactory
CommandsFactory to create a command from raw data read off a stream.
CacheEntry instead of the corresponding value associated with the key.
DummyBaseTransactionManager.begin() method.
DummyUserTransaction.begin() method.
MultipleRpcCommand, but it only aggregates a single command for
replication.Environment, then opens the databases.
StateTransferManager instances.ComponentStatus.TERMINATED once it
is done.
CacheStore.store(org.infinispan.container.entries.InternalCacheEntry)Element.
CacheLoader implemtations thread safe.StripedLock.StripedLock(int) with a default concurrency value of 20.
ComponentRegistry,
that are meant to be retained in the component registry even after the component registry is stopped.InternalCacheValue.
key value.
Fqn.SEPARATOR and joining each subsequent
element with a Fqn.SEPARATOR.
Properties instance to an instance of TypedProperties
Properties instance to an instance of TypedProperties, if needed.
TransactionContext interface.GlobalTransactionTransactionCompleted.
if (txLogger.logIfNeeded(cmd)) {
// do NOT proceed with executing this command!
} else {
// proceed with executing this command as per normal!
}
When draining, the following pattern should be used:
List<WriteCommand> c = null;
while (txLogger.shouldDrainWithoutLock()) {
c = txLogger.drain();
applyCommands(c);
}
c = txLogger.drainAndLock();
applyCommands(c);
applyPendingPrepares(txLogger.getPendingPrepares());
txLogger.unlockAndDisable();
Cache to use different transactional systems.Synchronization with a registered TransactionManager.TransactionRegistered.RemoteTransaction and TransactionXaAdapters (locally originated transactions).CacheTransaction and implementor of an XAResource that will be called by tx manager on various tx stages.TransientCacheEntryTransientMortalCacheEntryCache allowing for efficient tree-style access to cached data.TreeCacheObjectInput that delegates all methods except ObjectInput.close().ObjectOutput.ComponentsJmxRegistration.registerMBeans().
JdbcStringBasedCacheStore when one tries to
persist a StoredEntry with an unsupported key type.Collection view of the values contained in this map.
JBossMarshaller.ViewChanged.Map.get(Object).
LinkedHashSet except that it sets the underlying LinkedHashMap's accessOrder constructor parameter to true, allowing for recording of
visits.Visitors, such as CommandInterceptors.Inject annotation, creating more components
as needed based on the Configuration passed in if these additional components don't exist in the ComponentRegistry.
|
Google Analytics | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||