Uses of Interface
org.infinispan.container.entries.CacheEntry

Packages that use CacheEntry

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.cache.impl
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.conflict	This package contains the APIs that enable users to search for, and amend, data inconsistencies within their cache.
org.infinispan.container.entries	Entries which are stored in data containers.
org.infinispan.container.entries.metadata
org.infinispan.container.impl	Data containers which store cache entries.
org.infinispan.context	Contexts contain information of a specific invocation on the cache, such as its origins, scope (transactional or non-transactional), as well as invocation-specific flags.
org.infinispan.context.impl	This package contains different context implementations, selected dynamically based on the type of invocation.
org.infinispan.distribution.group.impl
org.infinispan.filter	Provides capabilities around filtering and converting entries that are found in the cache or cache store/loader.
org.infinispan.functional.impl
org.infinispan.metadata	Metadata interfaces
org.infinispan.multimap.api.embedded	Embedded Multimap Cache.
org.infinispan.multimap.impl
org.infinispan.notifications.cachelistener	Cache-specific notifications and eventing.
org.infinispan.reactive.publisher.impl
org.infinispan.rest.stream
org.infinispan.security.actions
org.infinispan.security.impl
org.infinispan.server.hotrod
org.infinispan.server.hotrod.iteration
org.infinispan.stream	Cache stream processing.
org.infinispan.stream.impl
org.infinispan.transaction.impl
org.infinispan.transaction.xa	XA transaction support.
org.infinispan.util	General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.

Uses of CacheEntry in org.infinispan

Methods in org.infinispan that return CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	AdvancedCache.getCacheEntry(Object key)	Retrieves a CacheEntry corresponding to a specific key.

Methods in org.infinispan that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
CacheSet<CacheEntry<K,V>>	AdvancedCache.cacheEntrySet()	Identical to Cache.entrySet() but is typed to return CacheEntries instead of Entries.
Map<K,CacheEntry<K,V>>	AdvancedCache.getAllCacheEntries(Set<?> keys)	Gets a collection of entries from the AdvancedCache, returning them as Map of the cache entries associated with the set of keys requested.
default CompletableFuture<CacheEntry<K,V>>	AdvancedCache.getCacheEntryAsync(Object key)	Retrieves a CacheEntry corresponding to a specific key.
Iterator<CacheEntry<K,V>>	LockedStream.iterator()	This method is not supported when using a LockedStream
CompletableFuture<CacheEntry<K,V>>	AdvancedCache.putAsyncEntry(K key, V value, Metadata metadata)	Extension of AdvancedCache.putAsync(K, V, Metadata) which returns a CacheEntry instead of only the previous value.
default CompletionStage<CacheEntry<K,V>>	AdvancedCache.putAsyncReturnEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	AdvancedCache.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)	An extension form of AdvancedCache.putIfAbsentAsync(K, V, Metadata), which returns a CacheEntry instead of only the value.
default CompletionStage<CacheEntry<K,V>>	AdvancedCache.putIfAbsentAsyncReturnEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	AdvancedCache.removeAsyncEntry(Object key)	An extension of AsyncCache.removeAsync(Object), which returns a CacheEntry instead of only the value.
default CompletionStage<CacheEntry<K,V>>	AdvancedCache.removeAsyncReturnEntry(K key)
CompletableFuture<CacheEntry<K,V>>	AdvancedCache.replaceAsyncEntry(K key, V value, Metadata metadata)	An extension of AdvancedCache.replaceAsync(K, V, Metadata), which returns a CacheEntry instead of only the value.
default CompletionStage<CacheEntry<K,V>>	AdvancedCache.replaceAsyncReturnEntry(K key, V value, Metadata metadata)
Spliterator<CacheEntry<K,V>>	LockedStream.spliterator()	This method is not supported when using a LockedStream

Method parameters in org.infinispan with type arguments of type CacheEntry

Modifier and Type	Method	Description
LockedStream<K,V>	LockedStream.filter(Predicate<? super CacheEntry<K,V>> predicate)	Returns a locked stream consisting of the elements of this stream that match the given predicate.
default LockedStream<K,V>	LockedStream.filter(SerializablePredicate<? super CacheEntry<K,V>> predicate)	Same as LockedStream.filter(Predicate) except that the Predicate must also implement Serializable
void	LockedStream.forEach(BiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer)	Performs an action for each element of this stream on the primary owner of the given key.
default void	LockedStream.forEach(SerializableBiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer)	Same as LockedStream.forEach(BiConsumer) except that the BiConsumer must also implement Serializable
<R> Map<K,R>	LockedStream.invokeAll(BiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction)	Performs a BiFunction for each element of this stream on the primary owner of each entry returning a value.
default <R> Map<K,R>	LockedStream.invokeAll(SerializableBiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction)	Same as LockedStream.invokeAll(BiFunction) except that the BiFunction must also implement Serializable

Uses of CacheEntry in org.infinispan.cache.impl

Methods in org.infinispan.cache.impl that return CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	AbstractDelegatingAdvancedCache.getCacheEntry(Object key)
final CacheEntry<K,V>	CacheImpl.getCacheEntry(Object key)
CacheEntry<K,V>	DecoratedCache.getCacheEntry(Object key)
CacheEntry<K,V>	EncoderCache.getCacheEntry(Object key)
CacheEntry<K,V>	SimpleCacheImpl.getCacheEntry(Object k)
CacheEntry<K,V>	StatsCollectingCache.getCacheEntry(Object k)
protected CacheEntry<K,V>	CacheBackedEntrySet.wrapElement(CacheEntry<K,V> e)

Methods in org.infinispan.cache.impl that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
CacheSet<CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.cacheEntrySet()
CacheSet<CacheEntry<K,V>>	CacheImpl.cacheEntrySet()
CacheSet<CacheEntry<K,V>>	DecoratedCache.cacheEntrySet()
CacheSet<CacheEntry<K,V>>	EncoderCache.cacheEntrySet()
CacheSet<CacheEntry<K,V>>	SimpleCacheImpl.cacheEntrySet()
Map<K,CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.getAllCacheEntries(Set<?> keys)
Map<K,CacheEntry<K,V>>	CacheImpl.getAllCacheEntries(Set<?> keys)
final Map<K,CacheEntry<K,V>>	CacheImpl.getAllCacheEntries(Set<?> keys, long explicitFlags, InvocationContext ctx)
Map<K,CacheEntry<K,V>>	DecoratedCache.getAllCacheEntries(Set<?> keys)
Map<K,CacheEntry<K,V>>	EncoderCache.getAllCacheEntries(Set<?> keys)
Map<K,CacheEntry<K,V>>	SimpleCacheImpl.getAllCacheEntries(Set<?> keys)
Map<K,CacheEntry<K,V>>	StatsCollectingCache.getAllCacheEntries(Set<?> keys)
CompletableFuture<CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.getCacheEntryAsync(Object key)
CompletableFuture<CacheEntry<K,V>>	CacheImpl.getCacheEntryAsync(Object key)
CompletableFuture<CacheEntry<K,V>>	DecoratedCache.getCacheEntryAsync(Object key)
CompletableFuture<CacheEntry<K,V>>	EncoderCache.getCacheEntryAsync(Object key)
CompletableFuture<CacheEntry<K,V>>	SimpleCacheImpl.getCacheEntryAsync(Object key)
protected Supplier<Stream<CacheEntry<K,V>>>	SimpleCacheImpl.getStreamSupplier(boolean parallel)
CloseableIterator<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.iterator()
static <K, V> EncoderEntryMapper<K,V,CacheEntry<K,V>>	EncoderEntryMapper.newCacheEntryMapper(DataConversion keyDataConversion, DataConversion valueDataConversion, InternalEntryFactory entryFactory)
CacheStream<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.parallelStream()
CompletableFuture<CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.putAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	CacheImpl.putAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	DecoratedCache.putAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	EncoderCache.putAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	SimpleCacheImpl.putAsyncEntry(K key, V value, Metadata metadata)
CompletionStage<CacheEntry<K,V>>	EncoderCache.putAsyncReturnEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	CacheImpl.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	DecoratedCache.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	EncoderCache.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	SimpleCacheImpl.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)
CompletionStage<CacheEntry<K,V>>	EncoderCache.putIfAbsentAsyncReturnEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.removeAsyncEntry(Object key)
CompletableFuture<CacheEntry<K,V>>	CacheImpl.removeAsyncEntry(Object key)
CompletableFuture<CacheEntry<K,V>>	DecoratedCache.removeAsyncEntry(Object key)
CompletableFuture<CacheEntry<K,V>>	EncoderCache.removeAsyncEntry(Object key)
CompletableFuture<CacheEntry<K,V>>	SimpleCacheImpl.removeAsyncEntry(Object key)
CompletionStage<CacheEntry<K,V>>	EncoderCache.removeAsyncReturnEntry(K key)
CompletableFuture<CacheEntry<K,V>>	AbstractDelegatingAdvancedCache.replaceAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	CacheImpl.replaceAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	DecoratedCache.replaceAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	EncoderCache.replaceAsyncEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	SimpleCacheImpl.replaceAsyncEntry(K key, V value, Metadata metadata)
CompletionStage<CacheEntry<K,V>>	EncoderCache.replaceAsyncReturnEntry(K key, V value, Metadata metadata)
CloseableSpliterator<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.spliterator()
CacheStream<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.stream()

Methods in org.infinispan.cache.impl with parameters of type CacheEntry

Modifier and Type	Method	Description
boolean	SimpleCacheImpl.CacheEntrySet.add(CacheEntry<K,V> entry)
protected CacheEntry<K,V>	CacheBackedEntrySet.wrapElement(CacheEntry<K,V> e)

Method parameters in org.infinispan.cache.impl with type arguments of type CacheEntry

Modifier and Type	Method	Description
boolean	SimpleCacheImpl.CacheEntrySet.addAll(Collection<? extends CacheEntry<K,V>> c)

Uses of CacheEntry in org.infinispan.commands

Method parameters in org.infinispan.commands with type arguments of type CacheEntry

Modifier and Type	Method	Description
<K, V, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	CommandsFactory.buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<K, V, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	CommandsFactoryImpl.buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Uses of CacheEntry in org.infinispan.conflict

Methods in org.infinispan.conflict that return CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	EntryMergePolicy.merge(CacheEntry<K,V> preferredEntry, List<CacheEntry<K,V>> otherEntries)	This method is called by ConflictManager.resolveConflicts() for each conflict discovered to determine which CacheEntry should be utilised.
CacheEntry	MergePolicy.merge(CacheEntry preferredEntry, List otherEntries)
CacheEntry	MergePolicy.UnsupportedMergePolicy.merge(CacheEntry preferredEntry, List otherEntries)

Methods in org.infinispan.conflict that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
Stream<Map<Address,CacheEntry<K,V>>>	ConflictManager.getConflicts()	Returns a stream of conflicts detected in the cluster.

Methods in org.infinispan.conflict with parameters of type CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	EntryMergePolicy.merge(CacheEntry<K,V> preferredEntry, List<CacheEntry<K,V>> otherEntries)	This method is called by ConflictManager.resolveConflicts() for each conflict discovered to determine which CacheEntry should be utilised.
CacheEntry	MergePolicy.merge(CacheEntry preferredEntry, List otherEntries)
CacheEntry	MergePolicy.UnsupportedMergePolicy.merge(CacheEntry preferredEntry, List otherEntries)

Method parameters in org.infinispan.conflict with type arguments of type CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	EntryMergePolicy.merge(CacheEntry<K,V> preferredEntry, List<CacheEntry<K,V>> otherEntries)	This method is called by ConflictManager.resolveConflicts() for each conflict discovered to determine which CacheEntry should be utilised.

Uses of CacheEntry in org.infinispan.container.entries

Subinterfaces of CacheEntry in org.infinispan.container.entries

Modifier and Type	Interface	Description
interface	InternalCacheEntry<K,V>	Interface for internal cache entries that expose whether an entry has expired.
interface	MVCCEntry<K,V>	An entry that can be safely copied when updates are made, to provide MVCC semantics

Classes in org.infinispan.container.entries that implement CacheEntry

Modifier and Type	Class	Description
class	AbstractInternalCacheEntry	An abstract internal cache entry that is typically stored in the data container
class	ClearCacheEntry<K,V>	Used in ClearInvocationContext to process the ClearCommand.
class	ForwardingCacheEntry<K,V>	A class designed to forward all method invocations for a CacheEntry to the provided delegate.
class	ImmortalCacheEntry	A cache entry that is immortal/cannot expire
class	L1InternalCacheEntry	A InternalCacheEntry implementation to store a L1 entry.
class	MortalCacheEntry	A cache entry that is mortal.
class	NullCacheEntry<K,V>
class	ReadCommittedEntry<K,V>	A wrapper around a cached entry that encapsulates read committed semantics when writes are initiated, committed or rolled back.
class	RepeatableReadEntry<K,V>	An extension of ReadCommittedEntry that provides Repeatable Read semantics
class	TransientCacheEntry	A cache entry that is transient, i.e., it can be considered expired after a period of not being used.
class	TransientMortalCacheEntry	A cache entry that is both transient and mortal.
class	VersionedRepeatableReadEntry<K,V>	A version of RepeatableReadEntry that can perform write-skew checks during prepare.

Methods in org.infinispan.container.entries that return CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	CacheEntry.clone()
CacheEntry<K,V>	ClearCacheEntry.clone()
CacheEntry<K,V>	ForwardingCacheEntry.clone()
CacheEntry	NullCacheEntry.clone()
protected abstract CacheEntry<K,V>	ForwardingCacheEntry.delegate()

Uses of CacheEntry in org.infinispan.container.entries.metadata

Classes in org.infinispan.container.entries.metadata that implement CacheEntry

Modifier and Type	Class	Description
class	L1MetadataInternalCacheEntry	A InternalCacheEntry implementation to store a L1 entry.
class	MetadataImmortalCacheEntry	A form of ImmortalCacheEntry that is MetadataAware
class	MetadataMortalCacheEntry	A cache entry that is mortal and is MetadataAware
class	MetadataTransientCacheEntry	A cache entry that is transient, i.e., it can be considered expired after a period of not being used, and MetadataAware
class	MetadataTransientMortalCacheEntry	A form of TransientMortalCacheEntry that stores Metadata

Uses of CacheEntry in org.infinispan.container.impl

Methods in org.infinispan.container.impl that return CacheEntry

Modifier and Type	Method	Description
<K, V> CacheEntry<K,V>	InternalEntryFactory.copy(CacheEntry<K,V> cacheEntry)	Creates a copy of this cache entry and synchronizes serializes the copy process with the InternalEntryFactory.update(org.infinispan.container.entries.InternalCacheEntry, org.infinispan.metadata.Metadata).
CacheEntry	InternalEntryFactoryImpl.copy(CacheEntry cacheEntry)

Methods in org.infinispan.container.impl with parameters of type CacheEntry

Modifier and Type	Method	Description
<K, V> CacheEntry<K,V>	InternalEntryFactory.copy(CacheEntry<K,V> cacheEntry)	Creates a copy of this cache entry and synchronizes serializes the copy process with the InternalEntryFactory.update(org.infinispan.container.entries.InternalCacheEntry, org.infinispan.metadata.Metadata).
CacheEntry	InternalEntryFactoryImpl.copy(CacheEntry cacheEntry)
<K, V> InternalCacheEntry<K,V>	InternalEntryFactory.create(CacheEntry<K,V> cacheEntry)	Creates a new InternalCacheEntry instance based on the key, value, version and timestamp/lifespan information reflected in the CacheEntry instance passed in.
InternalCacheEntry	InternalEntryFactoryImpl.create(CacheEntry cacheEntry)
<V> InternalCacheValue<V>	InternalEntryFactory.createValue(CacheEntry<?,V> cacheEntry)	Creates an InternalCacheValue based on the InternalCacheEntry passed in.
InternalCacheValue	InternalEntryFactoryImpl.createValue(CacheEntry cacheEntry)
protected MVCCEntry<?,?>	EntryFactoryImpl.createWrappedEntry(Object key, CacheEntry<?,?> cacheEntry)
void	EntryFactory.wrapExternalEntry(InvocationContext ctx, Object key, CacheEntry externalEntry, boolean isRead, boolean isWrite)	Insert an external entry (e.g.
void	EntryFactoryImpl.wrapExternalEntry(InvocationContext ctx, Object key, CacheEntry externalEntry, boolean isRead, boolean isWrite)

Uses of CacheEntry in org.infinispan.context

Methods in org.infinispan.context that return CacheEntry

Modifier and Type	Method	Description
CacheEntry	EntryLookup.lookupEntry(Object key)	Retrieves an entry from the collection of looked up entries in the current scope.

Methods in org.infinispan.context that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
Map<Object,CacheEntry>	EntryLookup.getLookedUpEntries()	Retrieves a map of entries looked up within the current scope.
<K, V> org.reactivestreams.Publisher<CacheEntry<K,V>>	EntryLookup.publisher()	Returns a Publisher that when subscribed to provide all values that have a value in the given context.

Methods in org.infinispan.context with parameters of type CacheEntry

Modifier and Type	Method	Description
void	EntryLookup.putLookedUpEntry(Object key, CacheEntry e)	Puts an entry in the registry of looked up entries in the current scope.

Method parameters in org.infinispan.context with type arguments of type CacheEntry

Modifier and Type	Method	Description
default void	EntryLookup.forEachEntry(BiConsumer<Object,CacheEntry> action)	Execute an action for each entry in the context.
default void	EntryLookup.forEachValue(BiConsumer<Object,CacheEntry> action)	Execute an action for each value in the context.

Uses of CacheEntry in org.infinispan.context.impl

Methods in org.infinispan.context.impl that return CacheEntry

Modifier and Type	Method	Description
CacheEntry	SingleKeyNonTxInvocationContext.getCacheEntry()
final CacheEntry	AbstractTxInvocationContext.lookupEntry(Object key)
CacheEntry	ClearInvocationContext.lookupEntry(Object key)
CacheEntry	ImmutableContext.lookupEntry(Object key)
CacheEntry	NonTxInvocationContext.lookupEntry(Object k)
CacheEntry	SingleKeyNonTxInvocationContext.lookupEntry(Object key)

Methods in org.infinispan.context.impl that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
final Map<Object,CacheEntry>	AbstractTxInvocationContext.getLookedUpEntries()
Map<Object,CacheEntry>	ClearInvocationContext.getLookedUpEntries()
Map<Object,CacheEntry>	ImmutableContext.getLookedUpEntries()
Map<Object,CacheEntry>	NonTxInvocationContext.getLookedUpEntries()
Map<Object,CacheEntry>	SingleKeyNonTxInvocationContext.getLookedUpEntries()
<K, V> org.reactivestreams.Publisher<CacheEntry<K,V>>	AbstractInvocationContext.publisher()
<K, V> org.reactivestreams.Publisher<CacheEntry<K,V>>	ImmutableContext.publisher()
<K, V> org.reactivestreams.Publisher<CacheEntry<K,V>>	SingleKeyNonTxInvocationContext.publisher()

Methods in org.infinispan.context.impl with parameters of type CacheEntry

Modifier and Type	Method	Description
final void	AbstractTxInvocationContext.putLookedUpEntry(Object key, CacheEntry e)
void	ClearInvocationContext.putLookedUpEntry(Object key, CacheEntry e)
void	ImmutableContext.putLookedUpEntry(Object key, CacheEntry e)
void	NonTxInvocationContext.putLookedUpEntry(Object key, CacheEntry e)
void	SingleKeyNonTxInvocationContext.putLookedUpEntry(Object key, CacheEntry e)

Method parameters in org.infinispan.context.impl with type arguments of type CacheEntry

Modifier and Type	Method	Description
void	ImmutableContext.forEachEntry(BiConsumer<Object,CacheEntry> action)
void	NonTxInvocationContext.forEachEntry(BiConsumer<Object,CacheEntry> action)
void	SingleKeyNonTxInvocationContext.forEachEntry(BiConsumer<Object,CacheEntry> action)
void	ImmutableContext.forEachValue(BiConsumer<Object,CacheEntry> action)
void	SingleKeyNonTxInvocationContext.forEachValue(BiConsumer<Object,CacheEntry> action)

Uses of CacheEntry in org.infinispan.distribution.group.impl

Methods in org.infinispan.distribution.group.impl with parameters of type CacheEntry

Modifier and Type	Method	Description
boolean	CacheEntryGroupPredicate.test(CacheEntry<K,?> entry)

Method parameters in org.infinispan.distribution.group.impl with type arguments of type CacheEntry

Modifier and Type	Method	Description
<K, V> Map<K,V>	GroupManager.collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)	Collects all entries belonging to a single group.
<K, V> Map<K,V>	GroupManagerImpl.collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)

Uses of CacheEntry in org.infinispan.filter

Methods in org.infinispan.filter that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
static <K, V, C> Function<CacheEntry<K,V>,CacheEntry<K,C>>	CacheFilters.converterToFunction(KeyValueFilterConverter<? super K,? super V,C> filterConverter)	Creates a new Function using the provided filter convert.
static <K, V, C> Function<CacheEntry<K,V>,CacheEntry<K,C>>	CacheFilters.converterToFunction(KeyValueFilterConverter<? super K,? super V,C> filterConverter)	Creates a new Function using the provided filter convert.
static <K, V, C> Stream<CacheEntry<K,C>>	CacheFilters.filterAndConvert(Stream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)	Adds needed intermediate operations to the provided stream, returning a possibly new stream as a result of the operations.
static <K, V, C> CacheStream<CacheEntry<K,C>>	CacheFilters.filterAndConvert(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> Function<CacheEntry<K,V>,CacheEntry<K,C>>	CacheFilters.function(Converter<? super K,? super V,C> converter)	Creates a new Function using the provided converter as a basis for the operation.
static <K, V, C> Function<CacheEntry<K,V>,CacheEntry<K,C>>	CacheFilters.function(Converter<? super K,? super V,C> converter)	Creates a new Function using the provided converter as a basis for the operation.
static <K, V> Predicate<CacheEntry<K,V>>	CacheFilters.notNullCacheEntryPredicate()	Provides a predicate that can be used to filter out null cache entry objects as well as placeholder "null" entries of NullCacheEntry that can be returned from methods such as CacheFilters.converterToFunction(KeyValueFilterConverter).
static <K, V> Predicate<CacheEntry<K,V>>	CacheFilters.predicate(KeyValueFilter<? super K,? super V> filter)	Creates a new Predicate using the provided key value filter as a basis for the operation.

Method parameters in org.infinispan.filter with type arguments of type CacheEntry

Modifier and Type	Method	Description
static <K, V, C> Stream<CacheEntry<K,C>>	CacheFilters.filterAndConvert(Stream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)	Adds needed intermediate operations to the provided stream, returning a possibly new stream as a result of the operations.
static <K, V, C> CacheStream<CacheEntry<K,C>>	CacheFilters.filterAndConvert(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> CacheStream<K>	CacheFilters.filterAndConvertToKey(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> CacheStream<C>	CacheFilters.filterAndConvertToValue(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)

Uses of CacheEntry in org.infinispan.functional.impl

Methods in org.infinispan.functional.impl with parameters of type CacheEntry

Modifier and Type	Method	Description
static <T> StatsEnvelope<T>	StatsEnvelope.create(T returnValue, CacheEntry<?,?> e, boolean exists, boolean isRead)
void	FunctionalNotifier.notifyOnCreate(CacheEntry<K,V> entry)	Notify registered Listeners.ReadWriteListeners.ReadWriteListener instances of the created entry.
void	FunctionalNotifierImpl.notifyOnCreate(CacheEntry entry)
void	FunctionalNotifier.notifyOnModify(CacheEntry<K,V> entry, V previousValue, Metadata previousMetadata)	Notify registered Listeners.ReadWriteListeners.ReadWriteListener instances of the modified entry passing the previous and new value.
void	FunctionalNotifierImpl.notifyOnModify(CacheEntry<K,V> entry, V previousValue, Metadata previousMetadata)
void	FunctionalNotifier.notifyOnWrite(CacheEntry<K,V> entry)
void	FunctionalNotifierImpl.notifyOnWrite(CacheEntry<K,V> entry)
static <K, V> EntryView.ReadEntryView<K,V>	EntryViews.readOnly(CacheEntry entry)
static <K, V> EntryView.ReadEntryView<K,V>	EntryViews.readOnly(CacheEntry<K,V> entry, DataConversion keyDataConversion, DataConversion valueDataConversion)
static <K, V> EntryView.WriteEntryView<K,V>	EntryViews.writeOnly(CacheEntry entry, DataConversion valueDataConversion)

Uses of CacheEntry in org.infinispan.metadata

Methods in org.infinispan.metadata with parameters of type CacheEntry

Modifier and Type	Method	Description
static void	Metadatas.updateMetadata(CacheEntry entry, Metadata providedMetadata)	Set the providedMetadata on the cache entry.

Uses of CacheEntry in org.infinispan.multimap.api.embedded

Methods in org.infinispan.multimap.api.embedded that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
CompletableFuture<Optional<CacheEntry<K,Collection<V>>>>	MultimapCache.getEntry(K key)	Retrieves a CacheEntry corresponding to a specific key in this multimap cache.

Uses of CacheEntry in org.infinispan.multimap.impl

Methods in org.infinispan.multimap.impl that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
CompletableFuture<Optional<CacheEntry<K,Collection<V>>>>	EmbeddedMultimapCache.getEntry(K key)

Uses of CacheEntry in org.infinispan.notifications.cachelistener

Methods in org.infinispan.notifications.cachelistener that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
org.reactivestreams.Publisher<CacheEntry<K,V>>	QueueingSegmentListener.apply(SegmentPublisherSupplier.Notification<CacheEntry<K,V>> cacheEntryNotification)	This should be invoked on a notification before actually processing the data.

Methods in org.infinispan.notifications.cachelistener with parameters of type CacheEntry

Modifier and Type	Method	Description
static CompletionStage<Void>	NotifyHelper.entryCommitted(CacheNotifier notifier, FunctionalNotifier functionalNotifier, boolean created, boolean removed, boolean expired, CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command, Object previousValue, Metadata previousMetadata, EvictionManager evictionManager)

Method parameters in org.infinispan.notifications.cachelistener with type arguments of type CacheEntry

Modifier and Type	Method	Description
org.reactivestreams.Publisher<CacheEntry<K,V>>	QueueingSegmentListener.apply(SegmentPublisherSupplier.Notification<CacheEntry<K,V>> cacheEntryNotification)	This should be invoked on a notification before actually processing the data.

Uses of CacheEntry in org.infinispan.reactive.publisher.impl

Method parameters in org.infinispan.reactive.publisher.impl with type arguments of type CacheEntry

Modifier and Type	Method	Description
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache, resulting in multiple values.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentAwarePublisherSupplier<R>	LocalPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache that is local, resulting in a stream of values of possibly varying size.
<R> SegmentAwarePublisherSupplier<R>	LocalPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Performs the given transformer and finalizer on data in the cache, resulting in a single value.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult<R>>	LocalPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Performs the given transformer and finalizer on data in the cache that is local, resulting in a single value.
<R> CompletionStage<org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult<R>>	LocalPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Uses of CacheEntry in org.infinispan.rest.stream

Constructor parameters in org.infinispan.rest.stream with type arguments of type CacheEntry

Modifier	Constructor	Description
	CacheEntryStreamProcessor(org.reactivestreams.Publisher<CacheEntry<?,?>> publisher, boolean keysAreJson, boolean valuesAreJson, boolean includeMetadata)

Uses of CacheEntry in org.infinispan.security.actions

Methods in org.infinispan.security.actions that return CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	GetCacheEntryAction.run()

Methods in org.infinispan.security.actions that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
CompletionStage<CacheEntry<K,V>>	GetCacheEntryAsyncAction.run()

Uses of CacheEntry in org.infinispan.security.impl

Methods in org.infinispan.security.impl that return CacheEntry

Modifier and Type	Method	Description
CacheEntry<K,V>	SecureCacheImpl.getCacheEntry(Object key)

Methods in org.infinispan.security.impl that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
CacheSet<CacheEntry<K,V>>	SecureCacheImpl.cacheEntrySet()
Map<K,CacheEntry<K,V>>	SecureCacheImpl.getAllCacheEntries(Set<?> keys)
CompletableFuture<CacheEntry<K,V>>	SecureCacheImpl.getCacheEntryAsync(Object key)
CompletableFuture<CacheEntry<K,V>>	SecureCacheImpl.putAsyncEntry(K key, V value, Metadata metadata)
CompletionStage<CacheEntry<K,V>>	SecureCacheImpl.putAsyncReturnEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	SecureCacheImpl.putIfAbsentAsyncEntry(K key, V value, Metadata metadata)
CompletionStage<CacheEntry<K,V>>	SecureCacheImpl.putIfAbsentAsyncReturnEntry(K key, V value, Metadata metadata)
CompletableFuture<CacheEntry<K,V>>	SecureCacheImpl.removeAsyncEntry(Object key)
CompletionStage<CacheEntry<K,V>>	SecureCacheImpl.removeAsyncReturnEntry(K key)
CompletableFuture<CacheEntry<K,V>>	SecureCacheImpl.replaceAsyncEntry(K key, V value, Metadata metadata)
CompletionStage<CacheEntry<K,V>>	SecureCacheImpl.replaceAsyncReturnEntry(K key, V value, Metadata metadata)

Uses of CacheEntry in org.infinispan.server.hotrod

Methods in org.infinispan.server.hotrod with parameters of type CacheEntry

Modifier and Type	Method	Description
static long	MetadataUtils.extractCreated(CacheEntry ce)
static long	MetadataUtils.extractLastUsed(CacheEntry ce)
static int	MetadataUtils.extractLifespan(CacheEntry ce)
static int	MetadataUtils.extractMaxIdle(CacheEntry ce)
static long	MetadataUtils.extractVersion(CacheEntry ce)
io.netty.buffer.ByteBuf	VersionedEncoder.getStreamResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int offset, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf	VersionedEncoder.getWithMetadataResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf	VersionedEncoder.multimapEntryResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[],Collection<byte[]>> ce)
io.netty.buffer.ByteBuf	VersionedEncoder.notExecutedResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[],byte[]> prev)
io.netty.buffer.ByteBuf	VersionedEncoder.successResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[],byte[]> result)
io.netty.buffer.ByteBuf	Encoder4x.valueResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[],byte[]> prev)
io.netty.buffer.ByteBuf	VersionedEncoder.valueResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[],byte[]> prev)

Uses of CacheEntry in org.infinispan.server.hotrod.iteration

Methods in org.infinispan.server.hotrod.iteration that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
List<CacheEntry>	IterableIterationResult.getEntries()

Uses of CacheEntry in org.infinispan.stream

Methods in org.infinispan.stream that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
static <K, V> Function<K,CacheEntry<K,V>>	StreamMarshalling.keyToEntryFunction()	Provides a function that given a key will return the CacheEntry that maps to this key.

Uses of CacheEntry in org.infinispan.stream.impl

Methods in org.infinispan.stream.impl that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
Iterator<CacheEntry<K,V>>	LockedStreamImpl.iterator()
Spliterator<CacheEntry<K,V>>	LockedStreamImpl.spliterator()

Method parameters in org.infinispan.stream.impl with type arguments of type CacheEntry

Modifier and Type	Method	Description
LockedStream<K,V>	LockedStreamImpl.filter(Predicate<? super CacheEntry<K,V>> predicate)
void	LockedStreamImpl.forEach(BiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer)
void	TxLockedStreamImpl.forEach(BiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer)
<R> Map<K,R>	LockedStreamImpl.invokeAll(BiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction)
<R> Map<K,R>	TxLockedStreamImpl.invokeAll(BiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction)

Constructor parameters in org.infinispan.stream.impl with type arguments of type CacheEntry

Modifier	Constructor	Description
	LockedStreamImpl(CacheStream<CacheEntry<K,V>> realStream, long time, TimeUnit unit)
	TxLockedStreamImpl(javax.transaction.TransactionManager tm, CacheStream<CacheEntry<K,V>> realStream, long time, TimeUnit unit)

Uses of CacheEntry in org.infinispan.transaction.impl

Fields in org.infinispan.transaction.impl with type parameters of type CacheEntry

Modifier and Type	Field	Description
protected Map<Object,CacheEntry>	AbstractCacheTransaction.lookedUpEntries

Methods in org.infinispan.transaction.impl that return CacheEntry

Modifier and Type	Method	Description
CacheEntry	AbstractCacheTransaction.lookupEntry(Object key)

Methods in org.infinispan.transaction.impl that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
Map<Object,CacheEntry>	AbstractCacheTransaction.getLookedUpEntries()
Map<Object,CacheEntry>	LocalTransaction.getLookedUpEntries()

Methods in org.infinispan.transaction.impl with parameters of type CacheEntry

Modifier and Type	Method	Description
static void	WriteSkewHelper.addVersionRead(TxInvocationContext<?> ctx, CacheEntry<?,?> entry, Object key, VersionGenerator versionGenerator, org.infinispan.util.logging.Log log)
static IncrementableEntryVersion	WriteSkewHelper.incrementVersion(CacheEntry<?,?> entry, VersionGenerator versionGenerator)
void	LocalTransaction.putLookedUpEntry(Object key, CacheEntry e)
void	RemoteTransaction.putLookedUpEntry(Object key, CacheEntry e)
static IncrementableEntryVersion	WriteSkewHelper.versionFromEntry(CacheEntry<?,?> entry)

Method parameters in org.infinispan.transaction.impl with type arguments of type CacheEntry

Modifier and Type	Method	Description
void	LocalTransaction.putLookedUpEntries(Map<Object,CacheEntry> entries)
void	RemoteTransaction.putLookedUpEntries(Map<Object,CacheEntry> entries)

Uses of CacheEntry in org.infinispan.transaction.xa

Methods in org.infinispan.transaction.xa that return CacheEntry

Modifier and Type	Method	Description
CacheEntry	CacheTransaction.lookupEntry(Object key)

Methods in org.infinispan.transaction.xa that return types with arguments of type CacheEntry

Modifier and Type	Method	Description
Map<Object,CacheEntry>	CacheTransaction.getLookedUpEntries()

Methods in org.infinispan.transaction.xa with parameters of type CacheEntry

Modifier and Type	Method	Description
void	CacheTransaction.putLookedUpEntry(Object key, CacheEntry e)

Method parameters in org.infinispan.transaction.xa with type arguments of type CacheEntry

Modifier and Type	Method	Description
void	CacheTransaction.putLookedUpEntries(Map<Object,CacheEntry> entries)

Uses of CacheEntry in org.infinispan.util

Classes in org.infinispan.util that implement CacheEntry

Modifier and Type	Class	Description
class	EntryWrapper<K,V>	Wrapper for CacheEntry(s) that can be used to update the cache when it's value is set.

Methods in org.infinispan.util that return CacheEntry

Modifier and Type	Method	Description
protected CacheEntry<K,V>	EntryWrapper.delegate()
CacheEntry<K,V>	DataContainerRemoveIterator.next()

Methods in org.infinispan.util with parameters of type CacheEntry

Modifier and Type	Method	Description
static Optional<IracMetadata>	IracUtils.findIracMetadataFromCacheEntry(CacheEntry<?,?> entry)
static IracEntryVersion	IracUtils.getIracVersionFromCacheEntry(CacheEntry<?,?> entry)
static void	IracUtils.setIracMetadata(CacheEntry<?,?> entry, int segment, IracMetadata metadata, IracTombstoneManager versionGenerator, LogSupplier logSupplier)	Stores the IracMetadata into CacheEntry.
static void	IracUtils.setPrivateMetadata(CacheEntry<?,?> entry, int segment, PrivateMetadata metadata, IracTombstoneManager versionGenerator, LogSupplier logSupplier)	Same as IracUtils.setIracMetadata(CacheEntry, int, IracMetadata, IracTombstoneManager, LogSupplier) but it stores a "full" PrivateMetadata instead of IracMetadata.

Constructors in org.infinispan.util with parameters of type CacheEntry

Modifier	Constructor	Description
	EntryWrapper(Cache<K,V> cache, CacheEntry<K,V> entry)	Creates a new entry wrapper given the cache and entry.