|
||||||||||
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)
.
SegmentReadLocker.deleteOrReleaseReadLock(String)
from deleting the file.
SegmentReadLocker.deleteOrReleaseReadLock(String)
from deleting the file.
AtomicMap
.AtomicHashMap
to provide consistency and isolation for concurrent readers
while writes may also be going on.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.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
.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.
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()
.
ExecutorFactory
based on an ThreadPoolExecutor
.Cache
instance, and is often used as a
starting point to using the Cache
.DefaultTwoWayKey2StringMapper
which is a replacement this implementation.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.Delta
s.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.
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.
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.
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
.
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.
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.
Fqn
passed in exists.
Object.hashCode()
.
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
which uses Infinispan to store Lucene indexes.InfinispanDirectory
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.
JdbcStringBasedCacheStore
, but will be injected through JdbcStringBasedCacheStore.doConnectionFactoryInitialization(org.infinispan.loaders.jdbc.connectionfactory.ConnectionFactory)
DeadlockDetectingGlobalTransaction.interruptProcessingThread()
will be ignored.
QueryIterator
with a given integer parameter - the fetchSize.
QueryIterator
.
GenericJBossMarshaller
, making use of a custom object table for types internal to
Infinispan.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
.StreamingMarshaller
of the cache.ResponseFilter
.KeyAffinityService
.KeyAffinityService
to generate the affinity keys.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.
Util.loadClass(String)
except that any ClassNotFoundException
s experienced is propagated
to the caller.
DistributedSegmentReadLocker
to minimize
remote operations in case several IndexReaders are opened on the same InfinispanDirectory
.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
.
MarshalledValue
s.DeltaAware
instance, and return a coherent and complete
DeltaAware
instance.
CacheStore
modificationModification
s to be performed atomically via TransactionRunner
.Modification
s that will be applied to the supplied CacheStore
ModuleProperties
class represents Infinispan's module configuration key value
pairs.MortalCacheEntry
ComponentName
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
KeyAffinityService
instance that generates keys mapped to all addresses
in the cluster.
KeyAffinityServiceFactory.newKeyAffinityService(org.infinispan.Cache, java.util.concurrent.Executor, KeyGenerator, int,
boolean)
with start == true;
KeyAffinityServiceFactory.newKeyAffinityService(org.infinispan.Cache, java.util.Collection, KeyGenerator,
java.util.concurrent.Executor, int, boolean)
with start == true.
KeyAffinityServiceFactory.newLocalKeyAffinityService(org.infinispan.Cache, KeyGenerator, java.util.concurrent.Executor, int, boolean)
with start == true.
named
logical grouping of data in the TreeCache
API of JBoss Cache
.AtomicMap
NotifyingFuture
.ObjectInput
ByteBuffer
which takes
an estimated size as parameter.
ByteBuffer
, which allows direct access to the byte
array with minimal array copying
ObjectOutput
HotRodOperation
objects.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 Cache
s, 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.TransactionManager
s.OwnableReentrantLock
s.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)
CacheQuery
XmlConfigHelper.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.
RemoteCache
s.Marshaller
for marshalling
keys and values to be send over to the remote Infinispan cluster.
RemoteCacheManager.RemoteCacheManager(Marshaller, java.util.Properties, boolean)
with start = true.
RemoteCacheManager.RemoteCacheManager(java.util.Properties, boolean)
, and it also starts the cache (start==true).
RemoteCacheManager.RemoteCacheManager(java.util.Properties)
, but it will try to lookup the config properties in the
classpath, in a file named hotrod-client.properties.
RemoteCacheManager.RemoteCacheManager(boolean)
and it also starts the cache.
RemoteCacheManager.RemoteCacheManager(String, int, boolean)
with start=true.
RemoteCacheManager.RemoteCacheManager(String, boolean)
, with start=true.
RemoteCacheManager.RemoteCacheManager(java.util.Properties)
, but it will try to lookup the config properties in
supplied URL.
RemoteCacheManager.RemoteCacheManager(java.net.URL)
and it also starts the cache (start==true).
RemoteCache
that is associated to an
RemoteCacheManager
that was not started.ReplicableCommand
s 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.Random
's distribution to generate keys.CacheStore.prepare(java.util.List, org.infinispan.transaction.xa.GlobalTransaction, boolean)
.
CacheStore.prepare(java.util.List, org.infinispan.transaction.xa.GlobalTransaction, boolean)
.
RequestBalancingStrategy
.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.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)
Marshaller
that supports streams.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.InfinispanDirectory
,
this factory produces instances of TransactionalSharedLuceneLock
.GlobalTransaction
TransactionCompleted
.
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 TransactionXaAdapter
s (locally originated transactions).CacheTransaction
and implementor of an XAResource
that will be called by tx manager on various tx stages.TransientCacheEntry
TransientMortalCacheEntry
Transport
objects.Cache
allowing for efficient tree-style access to cached data.TreeCache
Key2StringMapper
and allows a bidirectional transformation
between keys and strings.ObjectInput
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.Visitor
s, such as CommandInterceptor
s.Inject
annotation, creating more components
as needed based on the Configuration passed in if these additional components don't exist in the ComponentRegistry
.
Flag
s to the scope of a single invocation.
|
Google Analytics | |||||||||
PREV NEXT | FRAMES NO FRAMES |