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>
  • Method Details

    • 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

      org.infinispan.client.hotrod.impl.operations.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>
      flags -
      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)
    • resolveStorage

      default void resolveStorage(MediaType key, MediaType value, 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(org.infinispan.client.hotrod.impl.operations.OperationsFactory operationsFactory, Configuration configuration, ObjectName jmxParent)
    • init

      void init(org.infinispan.client.hotrod.impl.operations.OperationsFactory operationsFactory, Configuration configuration)
    • getOperationsFactory

      org.infinispan.client.hotrod.impl.operations.OperationsFactory getOperationsFactory()
    • isObjectStorage

      boolean isObjectStorage()
    • keyToBytes

      byte[] keyToBytes(Object o)
    • ping

      CompletionStage<org.infinispan.client.hotrod.impl.operations.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.
      stage that when complete the filter was sent to the listener node