io.micronaut.cache.infinispan

Class InfinispanAsyncCache

java.lang.Object

io.micronaut.cache.infinispan.InfinispanAsyncCache

All Implemented Interfaces:

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

public class InfinispanAsyncCache
extends java.lang.Object
implements 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) Resolve the given value for the given key.
<T> java.util.concurrent.CompletableFuture<T>	get(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType, java.util.function.Supplier<T> supplier) Resolve the given value for the given key.
org.reactivestreams.Publisher<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) Invalidate the value for the given key.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	invalidateAll() Invalidate all cached values within this cache.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	put(java.lang.Object key, java.lang.Object value) Cache the specified value using the specified key.
<T> java.util.concurrent.CompletableFuture<java.util.Optional<T>>	putIfAbsent(java.lang.Object key, T value) Cache the specified value using the specified key if it is not already present.

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)

Description copied from interface: AsyncCache

Resolve the given value for the given key.

Specified by:

get in interface AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

Type Parameters:

T - The concrete type

Parameters:

key - The cache key

requiredType - The required type

Returns:

An optional containing the value if it exists and is able to be converted to the specified type

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)

Description copied from interface: AsyncCache

Resolve the given value for the given key. If the value is not found the specified Supplier will be invoked and the return value cached.

Specified by:

get in interface AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

Type Parameters:

T - The concrete type

Parameters:

key - The cache key

requiredType - The required type

supplier - The supplier that should be invoked if the value is not found

Returns:

An optional containing the value if it exists and is able to be converted to the specified type

putIfAbsent

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

Description copied from interface: AsyncCache

Cache the specified value using the specified key if it is not already present.

Specified by:

putIfAbsent in interface AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

Type Parameters:

T - The concrete type

Parameters:

key - The key with which the specified value is to be associated

value - The value to be associated with the specified key

Returns:

An optional of the existing value or Optional.empty() if the specified value parameter was cached

put

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

Description copied from interface: AsyncCache

Cache the specified value using the specified key.

Specified by:

put in interface AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

Parameters:

key - The key with which the specified value is to be associated

value - The value to be associated with the specified key

Returns:

A future with a boolean indicating whether the operation was successful or not

invalidate

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

Description copied from interface: AsyncCache

Invalidate the value for the given key.

Specified by:

invalidate in interface AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

Parameters:

key - The key to invalid

Returns:

A future with a boolean indicating whether the operation was succesful or not

invalidateAll

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

Description copied from interface: AsyncCache

Invalidate all cached values within this cache.

Specified by:

invalidateAll in interface AsyncCache<org.infinispan.client.hotrod.RemoteCache<java.lang.Object,java.lang.Object>>

Returns:

A future with a boolean indicating whether the operation was succesful or not

getCacheInfo

public org.reactivestreams.Publisher<CacheInfo> getCacheInfo()

Specified by:

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

Returns:

The cache information.

getName

public java.lang.String getName()

Specified by:

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

Returns:

The name of the cache

getNativeCache

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

Specified by:

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

Returns:

The native cache implementation