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>
      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)
    • 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.
      Returns:
      stage that when complete the filter was sent to the listener node