Package | Description |
---|---|
org.infinispan.configuration.cache |
Cache configuration |
org.infinispan.configuration.serializing | |
org.infinispan.persistence |
Persistence API.
|
org.infinispan.persistence.internal | |
org.infinispan.persistence.manager |
Implementations of the
PersistenceManager interface, which define the logic
of how infinispan interacts with external stores. |
org.infinispan.persistence.spi |
The Persistence SPI.
|
org.infinispan.persistence.support |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStoreConfigurationBuilder<T extends StoreConfiguration,S extends AbstractStoreConfigurationBuilder<T,S>> |
interface |
StoreConfigurationBuilder<T extends StoreConfiguration,S extends StoreConfigurationBuilder<T,S>>
LoaderConfigurationBuilder is an interface which should be implemented by all cache loader builders
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractSegmentedStoreConfiguration<T extends AbstractStoreConfiguration>
Abstract store configuration that should be extended when the store configuration supports being segmented.
|
class |
AbstractStoreConfiguration |
class |
ClusterLoaderConfiguration
Deprecated.
since 11.0. To be removed in 14.0 ISPN-11864 with no direct replacement.
|
class |
CustomStoreConfiguration |
class |
SingleFileStoreConfiguration
Defines the configuration for the single file cache store.
|
Modifier and Type | Method and Description |
---|---|
List<StoreConfiguration> |
PersistenceConfiguration.stores() |
Modifier and Type | Method and Description |
---|---|
static boolean |
Configurations.isStateTransferStore(StoreConfiguration storeConfiguration) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractStoreSerializer.writeCommonStoreElements(XMLExtendedStreamWriter writer,
StoreConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
StoreConfiguration |
InitializationContextImpl.getConfiguration() |
Constructor and Description |
---|
InitializationContextImpl(StoreConfiguration configuration,
Cache cache,
KeyPartitioner keyPartitioner,
PersistenceMarshaller marshaller,
TimeService timeService,
ByteBufferFactory byteBufferFactory,
MarshallableEntryFactory marshallableEntryFactory,
Executor nonBlockingExecutor,
GlobalConfiguration globalConfiguration,
BlockingManager blockingManager) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
PersistenceUtil.createStoreInstance(StoreConfiguration config) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
PersistenceManager.clearAllStores(Predicate<? super StoreConfiguration> predicate)
Invokes
AdvancedCacheWriter.clear() on all the stores that aloes it. |
CompletionStage<Void> |
PersistenceManagerImpl.clearAllStores(Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManagerStub.clearAllStores(Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManager.commitAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate)
Perform the commit operation for the provided transaction on all Tx stores.
|
CompletionStage<Void> |
PersistenceManagerImpl.commitAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManagerStub.commitAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Boolean> |
PersistenceManager.deleteFromAllStores(Object key,
int segment,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Boolean> |
PersistenceManagerImpl.deleteFromAllStores(Object key,
int segment,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Boolean> |
PersistenceManagerStub.deleteFromAllStores(Object key,
int segment,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManager.prepareAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate)
Perform the prepare phase of 2PC on all Tx stores.
|
CompletionStage<Void> |
PersistenceManagerImpl.prepareAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManagerStub.prepareAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PassivationPersistenceManager.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManager.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate)
Returns a publisher that will publish entries that map to the provided segments.
|
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManagerImpl.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManagerStub.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PassivationPersistenceManager.publishEntries(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManager.publishEntries(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate)
Returns a publisher that will publish all entries stored by the underlying cache store.
|
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManagerImpl.publishEntries(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
PersistenceManagerStub.publishEntries(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PassivationPersistenceManager.publishKeys(IntSet segments,
Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PersistenceManager.publishKeys(IntSet segments,
Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate)
Returns a publisher that will publish keys that map to the provided segments.
|
<K> org.reactivestreams.Publisher<K> |
PersistenceManagerImpl.publishKeys(IntSet segments,
Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PersistenceManagerStub.publishKeys(IntSet segments,
Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PassivationPersistenceManager.publishKeys(Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PersistenceManager.publishKeys(Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate)
Returns a publisher that will publish all keys stored by the underlying cache store.
|
<K> org.reactivestreams.Publisher<K> |
PersistenceManagerImpl.publishKeys(Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
PersistenceManagerStub.publishKeys(Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManager.rollbackAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate)
Perform the rollback operation for the provided transaction on all Tx stores.
|
CompletionStage<Void> |
PersistenceManagerImpl.rollbackAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
PersistenceManagerStub.rollbackAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Long> |
PassivationPersistenceManager.size(Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Long> |
PersistenceManager.size(Predicate<? super StoreConfiguration> predicate)
Returns the count of how many entries are persisted.
|
CompletionStage<Long> |
PersistenceManagerImpl.size(Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Long> |
PersistenceManagerStub.size(Predicate<? super StoreConfiguration> predicate) |
<K,V> CompletionStage<Void> |
PersistenceManager.writeEntries(Iterable<MarshallableEntry<K,V>> iterable,
Predicate<? super StoreConfiguration> predicate)
Writes the entries to the stores that pass the given predicate
|
<K,V> CompletionStage<Void> |
PersistenceManagerImpl.writeEntries(Iterable<MarshallableEntry<K,V>> iterable,
Predicate<? super StoreConfiguration> predicate) |
<K,V> CompletionStage<Void> |
PersistenceManagerStub.writeEntries(Iterable<MarshallableEntry<K,V>> iterable,
Predicate<? super StoreConfiguration> predicate) |
default CompletionStage<Void> |
PersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry,
int segment,
Predicate<? super StoreConfiguration> predicate)
Write to all stores that are not transactional.
|
CompletionStage<Void> |
PersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry,
int segment,
Predicate<? super StoreConfiguration> predicate,
long flags) |
CompletionStage<Void> |
PersistenceManagerImpl.writeToAllNonTxStores(MarshallableEntry marshalledEntry,
int segment,
Predicate<? super StoreConfiguration> predicate,
long flags) |
CompletionStage<Void> |
PersistenceManagerStub.writeToAllNonTxStores(MarshallableEntry marshalledEntry,
int segment,
Predicate<? super StoreConfiguration> predicate,
long flags) |
Modifier and Type | Method and Description |
---|---|
<T extends StoreConfiguration> |
InitializationContext.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
DelegatingPersistenceManager.clearAllStores(Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
DelegatingPersistenceManager.commitAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Boolean> |
DelegatingPersistenceManager.deleteFromAllStores(Object key,
int segment,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
DelegatingPersistenceManager.prepareAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
DelegatingPersistenceManager.publishEntries(IntSet segments,
Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
DelegatingPersistenceManager.publishEntries(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
DelegatingPersistenceManager.publishKeys(IntSet segments,
Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
<K> org.reactivestreams.Publisher<K> |
DelegatingPersistenceManager.publishKeys(Predicate<? super K> filter,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
DelegatingPersistenceManager.rollbackAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Long> |
DelegatingPersistenceManager.size(Predicate<? super StoreConfiguration> predicate) |
<K,V> CompletionStage<Void> |
DelegatingPersistenceManager.writeEntries(Iterable<MarshallableEntry<K,V>> iterable,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
DelegatingPersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry,
int segment,
Predicate<? super StoreConfiguration> predicate) |
CompletionStage<Void> |
DelegatingPersistenceManager.writeToAllNonTxStores(MarshallableEntry marshalledEntry,
int segment,
Predicate<? super StoreConfiguration> predicate,
long flags) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.