Class DelegatingPersistenceManager
- java.lang.Object
-
- org.infinispan.persistence.support.DelegatingPersistenceManager
-
-
Field Summary
Fields Modifier and Type Field Description protected org.infinispan.persistence.manager.PersistenceManager
persistenceManager
-
Constructor Summary
Constructors Constructor Description DelegatingPersistenceManager(org.infinispan.persistence.manager.PersistenceManager persistenceManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletionStage<Boolean>
addSegments(IntSet segments)
CompletionStage<Void>
addStore(StoreConfiguration persistenceConfiguration)
void
addStoreListener(org.infinispan.persistence.manager.PersistenceManager.StoreChangeListener listener)
CompletionStage<Long>
approximateSize(Predicate<? super StoreConfiguration> predicate, IntSet segments)
CompletionStage<Void>
clearAllStores(Predicate<? super StoreConfiguration> predicate)
CompletionStage<Void>
commitAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext, Predicate<? super StoreConfiguration> predicate)
CompletionStage<Boolean>
deleteFromAllStores(Object key, int segment, Predicate<? super StoreConfiguration> predicate)
CompletionStage<Void>
disableStore(String storeType)
org.infinispan.persistence.manager.PersistenceManager
getActual()
<T> Set<T>
getStores(Class<T> storeClass)
Collection<String>
getStoresAsString()
boolean
hasStore(Predicate<StoreConfiguration> test)
boolean
hasWriter()
boolean
isAvailable()
boolean
isEnabled()
boolean
isReadOnly()
<K,V>
CompletionStage<MarshallableEntry<K,V>>loadFromAllStores(Object key, boolean localInvocation, boolean includeStores)
<K,V>
CompletionStage<MarshallableEntry<K,V>>loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores)
CompletionStage<Long>
performBatch(TxInvocationContext<AbstractCacheTransaction> invocationContext, BiPredicate<? super org.infinispan.commands.write.WriteCommand,Object> commandKeyPredicate)
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<Object,Object>>
preloadPublisher()
CompletionStage<Void>
prepareAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext, Predicate<? super StoreConfiguration> predicate)
<K,V>
org.reactivestreams.Publisher<MarshallableEntry<K,V>>publishEntries(boolean fetchValue, boolean fetchMetadata)
<K,V>
org.reactivestreams.Publisher<MarshallableEntry<K,V>>publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K,V>
org.reactivestreams.Publisher<MarshallableEntry<K,V>>publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
<K> org.reactivestreams.Publisher<K>
publishKeys(Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
<K> org.reactivestreams.Publisher<K>
publishKeys(IntSet segments, Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
CompletionStage<Void>
purgeExpired()
CompletionStage<Boolean>
removeSegments(IntSet segments)
void
removeStoreListener(org.infinispan.persistence.manager.PersistenceManager.StoreChangeListener listener)
CompletionStage<Void>
rollbackAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext, Predicate<? super StoreConfiguration> predicate)
void
setClearOnStop(boolean clearOnStop)
CompletionStage<Long>
size()
CompletionStage<Long>
size(Predicate<? super StoreConfiguration> predicate)
CompletionStage<Long>
size(Predicate<? super StoreConfiguration> predicate, IntSet segments)
void
start()
Invoked on component startvoid
stop()
Invoked on component stop<K,V>
CompletionStage<Void>writeEntries(Iterable<MarshallableEntry<K,V>> iterable, Predicate<? super StoreConfiguration> predicate)
CompletionStage<Long>
writeMapCommand(org.infinispan.commands.write.PutMapCommand putMapCommand, InvocationContext ctx, BiPredicate<? super org.infinispan.commands.write.PutMapCommand,Object> commandKeyPredicate)
CompletionStage<Void>
writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate)
CompletionStage<Void>
writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate, long flags)
-
-
-
Method Detail
-
start
public void start()
Description copied from interface:Lifecycle
Invoked on component start
-
stop
public void stop()
Description copied from interface:Lifecycle
Invoked on component stop
-
getActual
public org.infinispan.persistence.manager.PersistenceManager getActual()
-
isEnabled
public boolean isEnabled()
-
hasWriter
public boolean hasWriter()
-
hasStore
public boolean hasStore(Predicate<StoreConfiguration> test)
-
preloadPublisher
public io.reactivex.rxjava3.core.Flowable<MarshallableEntry<Object,Object>> preloadPublisher()
-
disableStore
public CompletionStage<Void> disableStore(String storeType)
-
addStore
public CompletionStage<Void> addStore(StoreConfiguration persistenceConfiguration)
-
addStoreListener
public void addStoreListener(org.infinispan.persistence.manager.PersistenceManager.StoreChangeListener listener)
-
removeStoreListener
public void removeStoreListener(org.infinispan.persistence.manager.PersistenceManager.StoreChangeListener listener)
-
getStoresAsString
public Collection<String> getStoresAsString()
-
purgeExpired
public CompletionStage<Void> purgeExpired()
-
clearAllStores
public CompletionStage<Void> clearAllStores(Predicate<? super StoreConfiguration> predicate)
-
deleteFromAllStores
public CompletionStage<Boolean> deleteFromAllStores(Object key, int segment, Predicate<? super StoreConfiguration> predicate)
-
publishEntries
public <K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
-
publishEntries
public <K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> publishEntries(IntSet segments, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, Predicate<? super StoreConfiguration> predicate)
-
publishKeys
public <K> org.reactivestreams.Publisher<K> publishKeys(Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
-
publishKeys
public <K> org.reactivestreams.Publisher<K> publishKeys(IntSet segments, Predicate<? super K> filter, Predicate<? super StoreConfiguration> predicate)
-
loadFromAllStores
public <K,V> CompletionStage<MarshallableEntry<K,V>> loadFromAllStores(Object key, boolean localInvocation, boolean includeStores)
-
size
public CompletionStage<Long> size(Predicate<? super StoreConfiguration> predicate)
-
setClearOnStop
public void setClearOnStop(boolean clearOnStop)
-
writeToAllNonTxStores
public CompletionStage<Void> writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate, long flags)
-
prepareAllTxStores
public CompletionStage<Void> prepareAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext, Predicate<? super StoreConfiguration> predicate) throws PersistenceException
- Throws:
PersistenceException
-
commitAllTxStores
public CompletionStage<Void> commitAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext, Predicate<? super StoreConfiguration> predicate)
-
rollbackAllTxStores
public CompletionStage<Void> rollbackAllTxStores(TxInvocationContext<AbstractCacheTransaction> txInvocationContext, Predicate<? super StoreConfiguration> predicate)
-
writeMapCommand
public CompletionStage<Long> writeMapCommand(org.infinispan.commands.write.PutMapCommand putMapCommand, InvocationContext ctx, BiPredicate<? super org.infinispan.commands.write.PutMapCommand,Object> commandKeyPredicate)
-
writeEntries
public <K,V> CompletionStage<Void> writeEntries(Iterable<MarshallableEntry<K,V>> iterable, Predicate<? super StoreConfiguration> predicate)
-
performBatch
public CompletionStage<Long> performBatch(TxInvocationContext<AbstractCacheTransaction> invocationContext, BiPredicate<? super org.infinispan.commands.write.WriteCommand,Object> commandKeyPredicate)
-
isAvailable
public boolean isAvailable()
-
isReadOnly
public boolean isReadOnly()
-
publishEntries
public <K,V> org.reactivestreams.Publisher<MarshallableEntry<K,V>> publishEntries(boolean fetchValue, boolean fetchMetadata)
-
loadFromAllStores
public <K,V> CompletionStage<MarshallableEntry<K,V>> loadFromAllStores(Object key, int segment, boolean localInvocation, boolean includeStores)
-
approximateSize
public CompletionStage<Long> approximateSize(Predicate<? super StoreConfiguration> predicate, IntSet segments)
-
size
public CompletionStage<Long> size()
-
size
public CompletionStage<Long> size(Predicate<? super StoreConfiguration> predicate, IntSet segments)
-
writeToAllNonTxStores
public CompletionStage<Void> writeToAllNonTxStores(MarshallableEntry marshalledEntry, int segment, Predicate<? super StoreConfiguration> predicate)
-
addSegments
public CompletionStage<Boolean> addSegments(IntSet segments)
-
removeSegments
public CompletionStage<Boolean> removeSegments(IntSet segments)
-
-