io.micronaut.cache.infinispan

Class InfinispanAsyncCache

java.lang.Object

io.micronaut.cache.infinispan.InfinispanAsyncCache

All Implemented Interfaces:

io.micronaut.cache.AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>, io.micronaut.cache.Cache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

public class InfinispanAsyncCache
extends java.lang.Object
implements io.micronaut.cache.AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

An AsyncCache implementation based on Infinispan's org.infinispan.commons.api.AsyncCache.

Since:

1.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor and Description
InfinispanAsyncCache(org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object> nativeCache, io.micronaut.core.convert.ConversionService<?> conversionService)

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)
org.reactivestreams.Publisher<io.micronaut.cache.CacheInfo>	getCacheInfo()
java.lang.String	getName()
org.infinispan.client.hotrod.RemoteCache<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

Constructor Detail

InfinispanAsyncCache

public InfinispanAsyncCache(org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object> nativeCache,
                            io.micronaut.core.convert.ConversionService<?> conversionService)

Parameters:

nativeCache - the Infinispan remote cache

conversionService - the conversion service

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<org.infinispan.client.hotrod.RemoteCache<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<org.infinispan.client.hotrod.RemoteCache<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<org.infinispan.client.hotrod.RemoteCache<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<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

invalidate

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

Specified by:

invalidate in interface io.micronaut.cache.AsyncCache<org.infinispan.client.hotrod.RemoteCache<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<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

getCacheInfo

public org.reactivestreams.Publisher<io.micronaut.cache.CacheInfo> getCacheInfo()

Specified by:

getCacheInfo in interface io.micronaut.cache.Cache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

getName

public java.lang.String getName()

Specified by:

getName in interface io.micronaut.cache.Cache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

getNativeCache

public org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object> getNativeCache()

Specified by:

getNativeCache in interface io.micronaut.cache.Cache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>