Package io.micronaut.cache.coherence

Class CoherenceAsyncCache

  • All Implemented Interfaces:
    io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>, io.micronaut.cache.Cache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>
    public class CoherenceAsyncCache
extends java.lang.Object
implements io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>
    A AsyncCache implementation based on Coherence.
    Since:
    1.0
    Author:
    Vaso Putica

    • Constructor Summary

      Constructors 
      Constructor Description
      CoherenceAsyncCache​(io.micronaut.core.convert.ConversionService<?> conversionService, com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object> nativeCache, java.util.concurrent.ExecutorService executorService)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> java.util.concurrent.CompletableFuture<java.util.Optional<T>> get​(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType)  
      <T> java.util.concurrent.CompletableFuture<T> get​(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType, java.util.function.Supplier<T> supplier)  
      java.lang.String getName()  
      com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object> getNativeCache()  
      java.util.concurrent.CompletableFuture<java.lang.Boolean> invalidate​(java.lang.Object key)  
      java.util.concurrent.CompletableFuture<java.lang.Boolean> invalidateAll()  
      java.util.concurrent.CompletableFuture<java.lang.Boolean> put​(java.lang.Object key, java.lang.Object value)  
      <T> java.util.concurrent.CompletableFuture<java.util.Optional<T>> putIfAbsent​(java.lang.Object key, T value)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

      • Methods inherited from interface io.micronaut.cache.AsyncCache

        get, get

      • Methods inherited from interface io.micronaut.cache.Cache

        getCacheInfo

    • Constructor Detail

      • CoherenceAsyncCache

        public CoherenceAsyncCache​(io.micronaut.core.convert.ConversionService<?> conversionService,
                           com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object> nativeCache,
                           java.util.concurrent.ExecutorService executorService)
        Parameters:
        conversionService - the conversion service
        nativeCache - the native cache
        executorService - manages the pool of executors

    • Method Detail

      • get

        @NonNull
public <T> java.util.concurrent.CompletableFuture<java.util.Optional<T>> get​(@NonNull
                                                                             java.lang.Object key,
                                                                             @NonNull
                                                                             io.micronaut.core.type.Argument<T> requiredType)
        Specified by:
        get in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • get

        public <T> java.util.concurrent.CompletableFuture<T> get​(@NonNull
                                                         java.lang.Object key,
                                                         @NonNull
                                                         io.micronaut.core.type.Argument<T> requiredType,
                                                         @NonNull
                                                         java.util.function.Supplier<T> supplier)
        Specified by:
        get in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • putIfAbsent

        @NonNull
public <T> java.util.concurrent.CompletableFuture<java.util.Optional<T>> putIfAbsent​(@NonNull
                                                                                     java.lang.Object key,
                                                                                     @NonNull
                                                                                     T value)
        Specified by:
        putIfAbsent in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • put

        public java.util.concurrent.CompletableFuture<java.lang.Boolean> put​(@NonNull
                                                                     java.lang.Object key,
                                                                     @NonNull
                                                                     java.lang.Object value)
        Specified by:
        put in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • invalidate

        public java.util.concurrent.CompletableFuture<java.lang.Boolean> invalidate​(java.lang.Object key)
        Specified by:
        invalidate in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • invalidateAll

        public java.util.concurrent.CompletableFuture<java.lang.Boolean> invalidateAll()
        Specified by:
        invalidateAll in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • getName

        public java.lang.String getName()
        Specified by:
        getName in interface io.micronaut.cache.Cache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>

      • getNativeCache

        public com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object> getNativeCache()
        Specified by:
        getNativeCache in interface io.micronaut.cache.Cache<com.tangosol.net.NamedCache<java.lang.Object,​java.lang.Object>>