Interface InternalRemoteCache<K,V>

All Superinterfaces:

AsyncCache<K,V>, BasicCache<K,V>, ConcurrentMap<K,V>, Lifecycle, Map<K,V>, RemoteCache<K,V>, TransactionalCache

All Known Implementing Classes:

DelegatingRemoteCache, InvalidatedNearRemoteCache, RemoteCacheImpl

public interface InternalRemoteCache<K,V>
extends RemoteCache<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Method Summary

Modifier and Type	Method	Description
io.netty.channel.Channel	addNearCacheListener(Object listener, int bloomBits)	Add a client listener to handle near cache with bloom filter optimization The listener object must be annotated with @ClientListener annotation.
CompletionStage<Void>	clear(org.infinispan.api.common.CacheOptions options)
ClientStatistics	clientStatistics()	Returns client-side statistics for this cache.
CompletionStage<org.infinispan.api.configuration.CacheConfiguration>	configuration()
Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>>	entries(org.infinispan.api.common.CacheOptions options)
CloseableIterator<Map.Entry<K,V>>	entryIterator(IntSet segments)
CompletionStage<Long>	estimateSize(org.infinispan.api.common.CacheOptions options)
int	flagInt()	Similar to RemoteCache.flags() except it returns the flags as an int instead of a set of enums
CompletionStage<V>	get(K key, org.infinispan.api.common.CacheOptions options)
Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>>	getAll(Set<K> keys, org.infinispan.api.common.CacheOptions options)
Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>>	getAll(org.infinispan.api.common.CacheOptions options, K[] keys)
CompletionStage<org.infinispan.api.common.CacheEntry<K,V>>	getAndRemove(K key, org.infinispan.api.common.CacheOptions options)
Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>>	getAndRemoveAll(Flow.Publisher<K> keys, org.infinispan.api.common.CacheWriteOptions options)
Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>>	getAndRemoveAll(Set<K> keys, org.infinispan.api.common.CacheWriteOptions options)
org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher	getDispatcher()
CompletionStage<org.infinispan.api.common.CacheEntry<K,V>>	getEntry(K key, org.infinispan.api.common.CacheOptions options)
ClientListenerNotifier	getListenerNotifier()
byte[]	getNameBytes()
org.infinispan.client.hotrod.impl.operations.CacheOperationsFactory	getOperationsFactory()
CompletionStage<org.infinispan.api.common.CacheEntry<K,V>>	getOrReplaceEntry(K key, V value, org.infinispan.api.common.CacheEntryVersion version, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<org.infinispan.client.hotrod.impl.operations.GetWithMetadataOperation.GetWithMetadataResult<V>>	getWithMetadataAsync(K key, io.netty.channel.Channel channel)
boolean	hasForceReturnFlag()
void	init(Configuration configuration, org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher)
void	init(Configuration configuration, org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher, ObjectName jmxParent)
CloseableIterator<K>	keyIterator(IntSet segments)
Flow.Publisher<K>	keys(org.infinispan.api.common.CacheOptions options)
byte[]	keyToBytes(Object o)
Flow.Publisher<org.infinispan.api.common.events.cache.CacheEntryEvent<K,V>>	listen(org.infinispan.api.common.events.cache.CacheListenerOptions options, org.infinispan.api.common.events.cache.CacheEntryEventType[] types)
InternalRemoteCache<K,V>	noFlags()	Resets all applied flags back to the defaults.
CompletionStage<org.infinispan.client.hotrod.impl.operations.PingResponse>	ping()
<T> Flow.Publisher<org.infinispan.api.common.process.CacheEntryProcessorResult<K,T>>	process(Set<K> keys, org.infinispan.api.async.AsyncCacheEntryProcessor<K,V,T> task, org.infinispan.api.common.CacheOptions options)
<T> Flow.Publisher<org.infinispan.api.common.process.CacheEntryProcessorResult<K,T>>	processAll(org.infinispan.api.async.AsyncCacheEntryProcessor<K,V,T> processor, org.infinispan.api.common.process.CacheProcessorOptions options)
CompletionStage<org.infinispan.api.common.CacheEntry<K,V>>	put(K key, V value, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<Void>	putAll(Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> entries, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<Void>	putAll(Map<K,V> entries, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<org.infinispan.api.common.CacheEntry<K,V>>	putIfAbsent(K key, V value, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<Boolean>	remove(K key, org.infinispan.api.common.CacheEntryVersion version, org.infinispan.api.common.CacheOptions options)
CompletionStage<Boolean>	remove(K key, org.infinispan.api.common.CacheOptions options)
Flow.Publisher<K>	removeAll(Flow.Publisher<K> keys, org.infinispan.api.common.CacheWriteOptions options)
Flow.Publisher<K>	removeAll(Set<K> keys, org.infinispan.api.common.CacheWriteOptions options)
default boolean	removeEntry(Map.Entry<K,V> entry)
default boolean	removeEntry(K key, V value)
CompletionStage<Boolean>	replace(K key, V value, org.infinispan.api.common.CacheEntryVersion version, org.infinispan.api.common.CacheWriteOptions options)
void	resolveStorage()
default void	resolveStorage(MediaType key, MediaType value)
CompletionStage<Void>	set(K key, V value, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<Boolean>	setIfAbsent(K key, V value, org.infinispan.api.common.CacheWriteOptions options)
CompletionStage<Void>	updateBloomFilter()	Sends the current bloom filter to the listener node where a near cache listener is installed.
<T,U> InternalRemoteCache<T,U>	withDataFormat(DataFormat dataFormat)	Return a new instance of RemoteCache using the supplied DataFormat.
InternalRemoteCache<K,V>	withFlags(Flag... flags)	Applies one or more Flags to the scope of a single invocation.

Methods inherited from interface org.infinispan.commons.api.AsyncCache

clearAsync, computeAsync, computeAsync, computeAsync, computeIfAbsentAsync, computeIfAbsentAsync, computeIfAbsentAsync, computeIfPresentAsync, computeIfPresentAsync, computeIfPresentAsync, containsKeyAsync, getAllAsync, getAsync, mergeAsync, mergeAsync, mergeAsync, putAsync, putAsync, putAsync, putIfAbsentAsync, putIfAbsentAsync, putIfAbsentAsync, removeAsync, removeAsync, replaceAsync, replaceAsync, replaceAsync, replaceAsync, replaceAsync, replaceAsync, sizeAsync

Methods inherited from interface org.infinispan.commons.api.BasicCache

compute, compute, computeIfAbsent, computeIfAbsent, computeIfPresent, computeIfPresent, continuousQuery, getName, getVersion, merge, merge, put, put, put, putIfAbsent, putIfAbsent, query, replace, replace

Methods inherited from interface java.util.concurrent.ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, replace, replaceAll

Methods inherited from interface org.infinispan.commons.api.Lifecycle

start, stop

Methods inherited from interface java.util.Map

clear, containsKey, containsValue, equals, get, hashCode, isEmpty, size

Methods inherited from interface org.infinispan.client.hotrod.RemoteCache

addClientListener, addClientListener, entrySet, entrySet, execute, execute, execute, flags, getAll, getCacheTopologyInfo, getDataFormat, getProtocolVersion, getRemoteCacheContainer, getRemoteCacheManager, getWithMetadata, getWithMetadataAsync, isTransactional, keySet, keySet, publishEntries, publishEntriesByQuery, publishEntriesWithMetadata, putAll, putAll, putAll, putAllAsync, putAllAsync, putAllAsync, remove, remove, removeClientListener, removeWithVersion, removeWithVersionAsync, replace, replace, replace, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersion, replaceWithVersionAsync, replaceWithVersionAsync, replaceWithVersionAsync, replaceWithVersionAsync, retrieveEntries, retrieveEntries, retrieveEntries, retrieveEntriesByQuery, retrieveEntriesWithMetadata, serverStatistics, serverStatisticsAsync, streaming, values, values

Methods inherited from interface org.infinispan.commons.api.TransactionalCache

getTransactionManager

Method Details

getNameBytes

byte[] getNameBytes()

keyIterator

CloseableIterator<K> keyIterator(IntSet segments)

entryIterator

CloseableIterator<Map.Entry<K,V>> entryIterator(IntSet segments)

removeEntry

default boolean removeEntry(Map.Entry<K,V> entry)

removeEntry

default boolean removeEntry(K key,
 V value)

getWithMetadataAsync

CompletionStage<org.infinispan.client.hotrod.impl.operations.GetWithMetadataOperation.GetWithMetadataResult<V>> getWithMetadataAsync(K key,
 io.netty.channel.Channel channel)

withFlags

InternalRemoteCache<K,V> withFlags(Flag... flags)

Description copied from interface: RemoteCache

Applies one or more Flags to the scope of a single invocation. See the Flag enumeration to for information on available flags. Sample usage:

    remoteCache.withFlags(Flag.FORCE_RETURN_VALUE).put("hello", "world");
 

Specified by:

withFlags in interface RemoteCache<K,V>

Parameters:

flags -

Returns:

a RemoteCache instance with the flag added if necessary

noFlags

InternalRemoteCache<K,V> noFlags()

Description copied from interface: RemoteCache

Resets all applied flags back to the defaults. Note that Flag.FORCE_RETURN_VALUE will be cleared as well even if it was set via configuration.

Specified by:

noFlags in interface RemoteCache<K,V>

Returns:

a RemoteCache instance with no flags applied to it

flagInt

int flagInt()

Similar to RemoteCache.flags() except it returns the flags as an int instead of a set of enums

Returns:

flags set as an int

withDataFormat

<T,U> InternalRemoteCache<T,U> withDataFormat(DataFormat dataFormat)

Description copied from interface: RemoteCache

Return a new instance of RemoteCache using the supplied DataFormat.

Specified by:

withDataFormat in interface RemoteCache<K,V>

hasForceReturnFlag

boolean hasForceReturnFlag()

resolveStorage

void resolveStorage()

resolveStorage

default void resolveStorage(MediaType key,
 MediaType value)

clientStatistics

ClientStatistics clientStatistics()

Description copied from interface: RemoteCache

Returns client-side statistics for this cache.

Specified by:

clientStatistics in interface RemoteCache<K,V>

init

void init(Configuration configuration,
 org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher)

init

void init(Configuration configuration,
 org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher,
 ObjectName jmxParent)

getDispatcher

org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher getDispatcher()

keyToBytes

byte[] keyToBytes(Object o)

ping

CompletionStage<org.infinispan.client.hotrod.impl.operations.PingResponse> ping()

addNearCacheListener

io.netty.channel.Channel addNearCacheListener(Object listener,
 int bloomBits)

Add a client listener to handle near cache with bloom filter optimization The listener object must be annotated with @ClientListener annotation.

updateBloomFilter

CompletionStage<Void> updateBloomFilter()

Sends the current bloom filter to the listener node where a near cache listener is installed. If this cache does not have near caching this will return an already completed stage.

Returns:

stage that when complete the filter was sent to the listener node

getOperationsFactory

org.infinispan.client.hotrod.impl.operations.CacheOperationsFactory getOperationsFactory()

getListenerNotifier

ClientListenerNotifier getListenerNotifier()

configuration

CompletionStage<org.infinispan.api.configuration.CacheConfiguration> configuration()

get

CompletionStage<V> get(K key,
 org.infinispan.api.common.CacheOptions options)

getEntry

CompletionStage<org.infinispan.api.common.CacheEntry<K,V>> getEntry(K key,
 org.infinispan.api.common.CacheOptions options)

putIfAbsent

CompletionStage<org.infinispan.api.common.CacheEntry<K,V>> putIfAbsent(K key,
 V value,
 org.infinispan.api.common.CacheWriteOptions options)

setIfAbsent

CompletionStage<Boolean> setIfAbsent(K key,
 V value,
 org.infinispan.api.common.CacheWriteOptions options)

put

CompletionStage<org.infinispan.api.common.CacheEntry<K,V>> put(K key,
 V value,
 org.infinispan.api.common.CacheWriteOptions options)

set

CompletionStage<Void> set(K key,
 V value,
 org.infinispan.api.common.CacheWriteOptions options)

replace

CompletionStage<Boolean> replace(K key,
 V value,
 org.infinispan.api.common.CacheEntryVersion version,
 org.infinispan.api.common.CacheWriteOptions options)

getOrReplaceEntry

CompletionStage<org.infinispan.api.common.CacheEntry<K,V>> getOrReplaceEntry(K key,
 V value,
 org.infinispan.api.common.CacheEntryVersion version,
 org.infinispan.api.common.CacheWriteOptions options)

remove

CompletionStage<Boolean> remove(K key,
 org.infinispan.api.common.CacheOptions options)

remove

CompletionStage<Boolean> remove(K key,
 org.infinispan.api.common.CacheEntryVersion version,
 org.infinispan.api.common.CacheOptions options)

getAndRemove

CompletionStage<org.infinispan.api.common.CacheEntry<K,V>> getAndRemove(K key,
 org.infinispan.api.common.CacheOptions options)

keys

Flow.Publisher<K> keys(org.infinispan.api.common.CacheOptions options)

entries

Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> entries(org.infinispan.api.common.CacheOptions options)

putAll

CompletionStage<Void> putAll(Map<K,V> entries,
 org.infinispan.api.common.CacheWriteOptions options)

putAll

CompletionStage<Void> putAll(Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> entries,
 org.infinispan.api.common.CacheWriteOptions options)

getAll

Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> getAll(Set<K> keys,
 org.infinispan.api.common.CacheOptions options)

getAll

Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> getAll(org.infinispan.api.common.CacheOptions options,
 K[] keys)

removeAll

Flow.Publisher<K> removeAll(Set<K> keys,
 org.infinispan.api.common.CacheWriteOptions options)

removeAll

Flow.Publisher<K> removeAll(Flow.Publisher<K> keys,
 org.infinispan.api.common.CacheWriteOptions options)

getAndRemoveAll

Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> getAndRemoveAll(Set<K> keys,
 org.infinispan.api.common.CacheWriteOptions options)

getAndRemoveAll

Flow.Publisher<org.infinispan.api.common.CacheEntry<K,V>> getAndRemoveAll(Flow.Publisher<K> keys,
 org.infinispan.api.common.CacheWriteOptions options)

estimateSize

CompletionStage<Long> estimateSize(org.infinispan.api.common.CacheOptions options)

clear

CompletionStage<Void> clear(org.infinispan.api.common.CacheOptions options)

listen

Flow.Publisher<org.infinispan.api.common.events.cache.CacheEntryEvent<K,V>> listen(org.infinispan.api.common.events.cache.CacheListenerOptions options,
 org.infinispan.api.common.events.cache.CacheEntryEventType[] types)

process

<T>
Flow.Publisher<org.infinispan.api.common.process.CacheEntryProcessorResult<K,T>> process(Set<K> keys,
 org.infinispan.api.async.AsyncCacheEntryProcessor<K,V,T> task,
 org.infinispan.api.common.CacheOptions options)

processAll

<T>
Flow.Publisher<org.infinispan.api.common.process.CacheEntryProcessorResult<K,T>> processAll(org.infinispan.api.async.AsyncCacheEntryProcessor<K,V,T> processor,
 org.infinispan.api.common.process.CacheProcessorOptions options)