Package org.infinispan.client.hotrod.impl

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, TransactionalRemoteCacheImpl

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

Nested Class Summary

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

Map.Entry<K extends Object,V extends Object>

Method Summary

Modifier and Type	Method	Description
SocketAddress	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.
ClientStatistics	clientStatistics()	Returns client-side statistics for this cache.
CloseableIterator<Map.Entry<K,V>>	entryIterator(IntSet segments)
OperationsFactory	getOperationsFactory()
RetryAwareCompletionStage<MetadataValue<V>>	getWithMetadataAsync(K key, SocketAddress preferredAddres)
boolean	hasForceReturnFlag()
void	init(OperationsFactory operationsFactory, Configuration configuration)
void	init(OperationsFactory operationsFactory, Configuration configuration, ObjectName jmxParent)
boolean	isObjectStorage()
K	keyAsObjectIfNeeded(Object key)
CloseableIterator<K>	keyIterator(IntSet segments)
byte[]	keyToBytes(Object o)
CompletionStage<PingResponse>	ping()
default boolean	removeEntry(Map.Entry<K,V> entry)
default boolean	removeEntry(K key, V value)
void	resolveStorage(boolean objectStorage)
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, getName, getVersion, merge, merge, put, put, put, putIfAbsent, putIfAbsent, 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, getAll, getCacheTopologyInfo, getDataFormat, getListeners, 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, stats, streaming, values, values

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

getTransactionManager

Method Detail

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

RetryAwareCompletionStage<MetadataValue<V>> getWithMetadataAsync(K key,
                                                                 SocketAddress preferredAddres)

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>

Returns:

the current RemoteCache instance to continue running operations on.

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(boolean objectStorage)

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(OperationsFactory operationsFactory,
          Configuration configuration,
          ObjectName jmxParent)

init

void init(OperationsFactory operationsFactory,
          Configuration configuration)

getOperationsFactory

OperationsFactory getOperationsFactory()

isObjectStorage

boolean isObjectStorage()

keyAsObjectIfNeeded

K keyAsObjectIfNeeded(Object key)

keyToBytes

byte[] keyToBytes(Object o)

ping

CompletionStage<PingResponse> ping()

addNearCacheListener

SocketAddress 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