Package 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<Object,Object>>, io.micronaut.cache.Cache<com.tangosol.net.NamedCache<Object,Object>>

public class CoherenceAsyncCache
extends Object
implements io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,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<Object,Object> nativeCache, ExecutorService executorService)

Method Summary

Modifier and Type	Method	Description
<T> @NonNull CompletableFuture<Optional<T>>	get(@NonNull Object key, @NonNull io.micronaut.core.type.Argument<T> requiredType)
<T> CompletableFuture<T>	get(@NonNull Object key, @NonNull io.micronaut.core.type.Argument<T> requiredType, @NonNull Supplier<T> supplier)
String	getName()
com.tangosol.net.NamedCache<Object,Object>	getNativeCache()
CompletableFuture<Boolean>	invalidate(Object key)
CompletableFuture<Boolean>	invalidateAll()
CompletableFuture<Boolean>	put(@NonNull Object key, @NonNull Object value)
<T> @NonNull CompletableFuture<Optional<T>>	putIfAbsent(@NonNull 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 Details

CoherenceAsyncCache

public CoherenceAsyncCache(io.micronaut.core.convert.ConversionService conversionService,
 com.tangosol.net.NamedCache<Object,Object> nativeCache,
 ExecutorService executorService)

Parameters:

conversionService - the conversion service

nativeCache - the native cache

executorService - manages the pool of executors

Method Details

get

@NonNull
public <T> @NonNull CompletableFuture<Optional<T>> get(@NonNull
 @NonNull Object key,
 @NonNull
 @NonNull io.micronaut.core.type.Argument<T> requiredType)

Specified by:

get in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,Object>>

get

public <T> CompletableFuture<T> get(@NonNull
 @NonNull Object key,
 @NonNull
 @NonNull io.micronaut.core.type.Argument<T> requiredType,
 @NonNull
 @NonNull Supplier<T> supplier)

Specified by:

get in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,Object>>

putIfAbsent

@NonNull
public <T> @NonNull CompletableFuture<Optional<T>> putIfAbsent(@NonNull
 @NonNull Object key,
 @NonNull
 T value)

Specified by:

putIfAbsent in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,Object>>

put

public CompletableFuture<Boolean> put(@NonNull
 @NonNull Object key,
 @NonNull
 @NonNull Object value)

Specified by:

put in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,Object>>

invalidate

public CompletableFuture<Boolean> invalidate(Object key)

Specified by:

invalidate in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,Object>>

invalidateAll

public CompletableFuture<Boolean> invalidateAll()

Specified by:

invalidateAll in interface io.micronaut.cache.AsyncCache<com.tangosol.net.NamedCache<Object,Object>>

getName

public String getName()

Specified by:

getName in interface io.micronaut.cache.Cache<com.tangosol.net.NamedCache<Object,Object>>

getNativeCache

public com.tangosol.net.NamedCache<Object,Object> getNativeCache()

Specified by:

getNativeCache in interface io.micronaut.cache.Cache<com.tangosol.net.NamedCache<Object,Object>>