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
public interface InternalRemoteCache<K,V> extends RemoteCache<K,V>

  • 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)