io.micronaut.cache.coherence

Class CoherenceAsyncCache

java.lang.Object

io.micronaut.cache.coherence.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 and 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

Modifier and Type	Method and 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>>