|
||||||||||
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
CacheNotifierImpl
ModuleLifecycle
interface, designed for easy
extension.AbstractConfigurationBean
.GlobalTransaction
TxInvocationContext
.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
.ClusteredGetCommand
s.ReplicableCommand
s.Visitor
interface allowing it to
intercept invocations on VisitableCommand
s.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.Configuration
s.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.
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
.
BucketBasedCacheStore
s 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.
ImmortalCacheEntry
Map.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.Directory
Directory
UnionConsistentHash
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.