io.micronaut.ignite

Class IgniteAsyncCache

java.lang.Object

io.micronaut.ignite.IgniteAsyncCache

All Implemented Interfaces:

io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>, io.micronaut.cache.Cache<org.apache.ignite.IgniteCache>

public class IgniteAsyncCache
extends java.lang.Object
implements io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

Constructor Summary

Constructors

Constructor and Description
IgniteAsyncCache(io.micronaut.core.convert.ConversionService<?> conversionService, org.apache.ignite.IgniteCache 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()
org.apache.ignite.IgniteCache	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

IgniteAsyncCache

public IgniteAsyncCache(io.micronaut.core.convert.ConversionService<?> conversionService,
                        org.apache.ignite.IgniteCache nativeCache,
                        java.util.concurrent.ExecutorService executorService)

Method Detail

get

public <T> java.util.concurrent.CompletableFuture<java.util.Optional<T>> get(java.lang.Object key,
                                                                             io.micronaut.core.type.Argument<T> requiredType)

Specified by:

get in interface io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

get

public <T> java.util.concurrent.CompletableFuture<T> get(java.lang.Object key,
                                                         io.micronaut.core.type.Argument<T> requiredType,
                                                         java.util.function.Supplier<T> supplier)

Specified by:

get in interface io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

putIfAbsent

public <T> java.util.concurrent.CompletableFuture<java.util.Optional<T>> putIfAbsent(java.lang.Object key,
                                                                                     T value)

Specified by:

putIfAbsent in interface io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

put

public java.util.concurrent.CompletableFuture<java.lang.Boolean> put(java.lang.Object key,
                                                                     java.lang.Object value)

Specified by:

put in interface io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

invalidate

public java.util.concurrent.CompletableFuture<java.lang.Boolean> invalidate(java.lang.Object key)

Specified by:

invalidate in interface io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

invalidateAll

public java.util.concurrent.CompletableFuture<java.lang.Boolean> invalidateAll()

Specified by:

invalidateAll in interface io.micronaut.cache.AsyncCache<org.apache.ignite.IgniteCache>

getName

public java.lang.String getName()

Specified by:

getName in interface io.micronaut.cache.Cache<org.apache.ignite.IgniteCache>

getNativeCache

public org.apache.ignite.IgniteCache getNativeCache()

Specified by:

getNativeCache in interface io.micronaut.cache.Cache<org.apache.ignite.IgniteCache>