Package org.infinispan.persistence.support

Class DelegatingPersistenceManager

java.lang.Object

org.infinispan.persistence.support.DelegatingPersistenceManager

All Implemented Interfaces:

Lifecycle, org.infinispan.persistence.manager.PersistenceManager

public class DelegatingPersistenceManager
extends Object
implements org.infinispan.persistence.manager.PersistenceManager, Lifecycle

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

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 start
void	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

persistenceManager

protected final org.infinispan.persistence.manager.PersistenceManager persistenceManager

Constructor Detail

DelegatingPersistenceManager

public DelegatingPersistenceManager(org.infinispan.persistence.manager.PersistenceManager persistenceManager)

Method Detail

start

public void start()

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

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)

getStores

public <T> Set<T> getStores(Class<T> storeClass)

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)