Package org.infinispan.persistence.internal

Class PersistenceUtil

java.lang.Object

org.infinispan.persistence.internal.PersistenceUtil

public class PersistenceUtil
extends Object

Persistence Utility that is useful for internal classes. Normally methods that require non public classes, such as PersistenceManager, should go in here.

Since:

9.4

Author:

William Burns

Constructor Summary

Constructors

Constructor	Description
PersistenceUtil()

Method Summary

Modifier and Type	Method	Description
static <K> Predicate<? super K>	combinePredicate(IntSet segments, KeyPartitioner keyPartitioner, Predicate<? super K> filter)
static <K, V> InternalCacheEntry<K,V>	convert(MarshallableEntry<K,V> loaded, InternalEntryFactory factory)
static <T> T	createStoreInstance(StoreConfiguration config)	Deprecated. This method is only public for use with prior Store classes, use storeFromConfiguration(StoreConfiguration) when dealing with NonBlockingStore instances
static <K, V> MarshallableEntry<K,V>	loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, int segment, InvocationContext context)
static <K, V> InternalCacheEntry<K,V>	loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, DataContainer.ComputeAction<K,V> action)
static <K, V> InternalCacheEntry<K,V>	loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
static <K, V> InternalCacheEntry<K,V>	loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
static <R> io.reactivex.rxjava3.core.Flowable<R>	parallelizePublisher(IntSet segments, io.reactivex.rxjava3.core.Scheduler scheduler, IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)
static <K, V> NonBlockingStore<K,V>	storeFromConfiguration(StoreConfiguration cfg)

Methods inherited from class java.lang.Object

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

Constructor Details

PersistenceUtil

public PersistenceUtil()

Method Details

loadAndStoreInDataContainer

public static <K,
V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
 org.infinispan.persistence.manager.PersistenceManager persistenceManager,
 K key,
 InvocationContext ctx,
 TimeService timeService,
 AtomicReference<Boolean> isLoaded)

loadAndStoreInDataContainer

public static <K,
V> InternalCacheEntry<K,V> loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
 int segment,
 org.infinispan.persistence.manager.PersistenceManager persistenceManager,
 K key,
 InvocationContext ctx,
 TimeService timeService,
 AtomicReference<Boolean> isLoaded)

loadAndComputeInDataContainer

public static <K,
V> InternalCacheEntry<K,V> loadAndComputeInDataContainer(DataContainer<K,V> dataContainer,
 int segment,
 org.infinispan.persistence.manager.PersistenceManager persistenceManager,
 K key,
 InvocationContext ctx,
 TimeService timeService,
 DataContainer.ComputeAction<K,V> action)

loadAndCheckExpiration

public static <K,
V> MarshallableEntry<K,V> loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager,
 Object key,
 int segment,
 InvocationContext context)

convert

public static <K,
V> InternalCacheEntry<K,V> convert(MarshallableEntry<K,V> loaded,
 InternalEntryFactory factory)

combinePredicate

public static <K> Predicate<? super K> combinePredicate(IntSet segments,
 KeyPartitioner keyPartitioner,
 Predicate<? super K> filter)

parallelizePublisher

public static <R>
io.reactivex.rxjava3.core.Flowable<R> parallelizePublisher(IntSet segments,
 io.reactivex.rxjava3.core.Scheduler scheduler,
 IntFunction<org.reactivestreams.Publisher<R>> publisherFunction)

createStoreInstance

public static <T> T createStoreInstance(StoreConfiguration config)

Deprecated.

This method is only public for use with prior Store classes, use storeFromConfiguration(StoreConfiguration) when dealing with NonBlockingStore instances

storeFromConfiguration

public static <K,
V> NonBlockingStore<K,V> storeFromConfiguration(StoreConfiguration cfg)