io.micronaut.cache.hazelcast

Class HazelcastAsyncCache

java.lang.Object

io.micronaut.cache.hazelcast.HazelcastAsyncCache

All Implemented Interfaces:

io.micronaut.cache.AsyncCache<com.hazelcast.core.IMap<java.lang.Object,java.lang.Object>>, io.micronaut.cache.Cache<com.hazelcast.core.IMap<java.lang.Object,java.lang.Object>>

public class HazelcastAsyncCache
extends java.lang.Object
implements io.micronaut.cache.AsyncCache<com.hazelcast.core.IMap<java.lang.Object,java.lang.Object>>

A AsyncCache implementation based on Hazelcast.

Since:

1.0.0

Author:

Nirav Assar

Constructor Summary

Constructors

Constructor and Description
HazelcastAsyncCache(io.micronaut.core.convert.ConversionService<?> conversionService, com.hazelcast.core.IMap<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.hazelcast.core.IMap	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

HazelcastAsyncCache

public HazelcastAsyncCache(io.micronaut.core.convert.ConversionService<?> conversionService,
                           com.hazelcast.core.IMap<java.lang.Object,java.lang.Object> nativeCache,
                           java.util.concurrent.ExecutorService executorService)

Parameters:

conversionService - the conversion service

nativeCache - the native cache

executorService - managers 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.hazelcast.core.IMap<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.hazelcast.core.IMap<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.hazelcast.core.IMap<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.hazelcast.core.IMap<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<com.hazelcast.core.IMap<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.hazelcast.core.IMap<java.lang.Object,java.lang.Object>>

getName

public java.lang.String getName()

Specified by:

getName in interface io.micronaut.cache.Cache<com.hazelcast.core.IMap<java.lang.Object,java.lang.Object>>

getNativeCache

public com.hazelcast.core.IMap getNativeCache()

Specified by:

getNativeCache in interface io.micronaut.cache.Cache<com.hazelcast.core.IMap<java.lang.Object,java.lang.Object>>