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

Method Summary

Modifier and Type	Method and Description
ClientStatistics	clientStatistics() Returns client-side statistics for this cache.
CloseableIterator<Map.Entry<K,V>>	entryIterator(IntSet segments)
OperationsFactory	getOperationsFactory()
boolean	hasForceReturnFlag()
void	init(Marshaller marshaller, OperationsFactory operationsFactory, Configuration configuration)
void	init(Marshaller marshaller, OperationsFactory operationsFactory, Configuration configuration, ObjectName jmxParent)
boolean	isObjectStorage()
K	keyAsObjectIfNeeded(Object key)
CloseableIterator<K>	keyIterator(IntSet segments)
byte[]	keyToBytes(Object o)
default boolean	removeEntry(K key, V value)
default boolean	removeEntry(Map.Entry<K,V> entry)
void	resolveStorage(boolean objectStorage)
<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.client.hotrod.RemoteCache

addClientListener, addClientListener, entrySet, entrySet, execute, execute, getAll, getCacheTopologyInfo, getDataFormat, getListeners, getProtocolVersion, 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, stats, streaming, values, values

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 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 java.util.concurrent.ConcurrentMap

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

Methods inherited from interface java.util.Map

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

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

start, stop

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)

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

init

void init(Marshaller marshaller,
          OperationsFactory operationsFactory,
          Configuration configuration)

getOperationsFactory

OperationsFactory getOperationsFactory()

isObjectStorage

boolean isObjectStorage()

keyAsObjectIfNeeded

K keyAsObjectIfNeeded(Object key)

keyToBytes

byte[] keyToBytes(Object o)