|
||||||||||
| 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.SegmentReadLocker.deleteOrReleaseReadLock(String)
from deleting the file.
SegmentReadLocker.deleteOrReleaseReadLock(String)
from deleting the file.
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).
AtomicMap.AtomicHashMap to provide consistency and isolation for concurrent readers
while writes may also be going on.Base64.InputStream will read data from another
java.io.InputStream, given in the constructor,
and encode/decode to/from Base64 notation on the fly.Base64.InputStream in DECODE mode.
Base64.InputStream in
either ENCODE or DECODE mode.
Base64.OutputStream will write data to another
java.io.OutputStream, given in the constructor,
and encode/decode to/from Base64 notation on the fly.Base64.OutputStream in ENCODE mode.
Base64.OutputStream in
either ENCODE or DECODE mode.
InfinispanDirectory,
this factory produces instances of BaseLuceneLock.Cache.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.
Cache instance, and is often
used as a starting point to using the Cache.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.QueryFactory.RpcManager only replicates commands wrapped in a CacheRpcCommand.CacheStarted.CacheStopped.CacheLoader interface that can be written to.CacheLoader based on Apache Cassandra project.CassandraCacheStore.CacheStore.clear() modificationMap.clear().
CloudCacheStore.ClusterCacheLoader.ClusteredGetCommands.ReplicableCommands.Visitor interface allowing it to
intercept invocations on VisitableCommands.DeltaAware.delta()) and can be
discarded.
TransactionXaAdapter.prepare(javax.transaction.xa.Xid) applies for commit.
FqnComparator.
tx.
ConcurrentHashMap to deal with the fact that the
JDK does not have a proper concurrent Set implementation that uses efficient lock striping.ConcurrentMap which is similar to ConcurrentHashMap.Configurations.ConnectionFactory.ConsistentHash function.MurmurHash2;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.
InvocationContextContainer.createRemoteInvocationContext(), but returning the flags to the context from
the Command if any Flag was set.
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.DldGlobalTransaction with
appropriate information needed in order to accomplish deadlock detection.Version.getVersionShort().
ExecutorFactory based on an ThreadPoolExecutor.Cache instance, and is often used as a
starting point to using the Cache.TwoWayKey2StringMapper that knows how to
handle all primitive wrapper keys and Strings.InfinispanIndexInput instances are reading from it, then it will
be effectively deleted.
DeltaAware implementation.Deltas.Modification objects and
executes it against the CacheStore. Current commands supported are: STORE CLEAR
REMOVE PURGE_EXPIRED
RemoteTransactionLogger.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.
RoundRobinBalancingStrategy.nextServer() without modifying indexes/state.
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.
Set view of the mappings contained in this map.
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.
null if this map contains no mapping for the
key.
RemoteCache.getBulk(), but limits the returned set of values to the specified size.
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
Util.getInstance(Class) except that exceptions are propagated to the caller.
Util.getInstance(String) except that exceptions are propagated to the caller.
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.
MBeanServer instance.
DefaultFactoryFor annotation that is capable of creating the component
class).
TransactionXaAdapter corresponding to the supplied transaction.
StringPropertyReplacer.replaceProperties(java.lang.String) to the result.
CacheQuery, filtered according to a set of classes passed
in.
RemoteCacheManager that created this cache.
RemoteTransaction associated with the supplied transaction id.
VersionedValue associated to the supplied key param, or null if it doesn't exist.