Class RedisConnectionPoolCache

java.lang.Object

io.micronaut.configuration.lettuce.cache.AbstractRedisCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>

io.micronaut.configuration.lettuce.cache.RedisConnectionPoolCache

All Implemented Interfaces:

io.micronaut.cache.Cache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>, io.micronaut.cache.SyncCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>, AutoCloseable

@EachBean(RedisCacheConfiguration.class)
@Requires(property="redis.enabled",notEquals="false") @Requires(classes=io.micronaut.cache.SyncCache.class,property="redis.pool.enabled",defaultValue="false",notEquals="false")
public class RedisConnectionPoolCache
extends AbstractRedisCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>

An implementation of SyncCache for Lettuce / Redis using connection pooling.

Since:

5.3.0

Author:

Graeme Rocher, Kovalov Illia

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	RedisConnectionPoolCache.RedisAsyncCache	Redis Async cache implementation.

Field Summary

Fields inherited from class AbstractRedisCache

expireAfterAccess, expireAfterWritePolicy, INVALID_REDIS_CONNECTION_MESSAGE, invalidateScanCount, keyPrefix, keySerializer, redisCacheConfiguration, valueSerializer

Constructor Summary

Constructors

Constructor	Description
RedisConnectionPoolCache(DefaultRedisCacheConfiguration defaultRedisCacheConfiguration, RedisCacheConfiguration redisCacheConfiguration, io.micronaut.core.convert.ConversionService conversionService, io.micronaut.context.BeanLocator beanLocator, io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>> asyncPool)	Creates a new redis cache for the given arguments.

Method Summary

Modifier and Type	Method	Description
io.micronaut.cache.AsyncCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>	async()
void	close()
<T> T	get(@NonNull Object key, @NonNull io.micronaut.core.type.Argument<T> requiredType, @NonNull Supplier<T> supplier)
<K> @NonNull Map<K,Object>	getAll(@NonNull Collection<K> keys)	Resolve the values for the given keys.
<K,T> @NonNull Map<K,T>	getAll(@NonNull Collection<K> keys, @NonNull io.micronaut.core.type.Argument<T> requiredType)	Resolve the values for the given keys.
String	getName()
io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>	getNativeCache()
protected <T> Optional<T>	getValue(io.micronaut.core.type.Argument<T> requiredType, byte[] serializedKey)	Get the value based on the parameters.
void	invalidate(Object key)
void	invalidateAll()
void	invalidateAllKeys(@NonNull Collection<?> keys)	Invalidate the values for the given keys.
void	putAll(@NonNull Map<?,?> values)	Cache the specified values in bulk.
protected <T> void	putValue(byte[] serializedKey, T value)	Place the value in the cache.

Methods inherited from class AbstractRedisCache

allKeys, allKeys, allKeys, allKeys, executeInsert, executeInsertAsync, executeRead, executeReadAsync, get, get, getKeysPattern, getRedisKeyAsyncCommands, getRedisKeyCommands, getRedisStringAsyncCommands, getRedisStringCommands, getValues, invalidateValues, put, putIfAbsent, putValue, putValues, serializeKey

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.cache.Cache

getCacheInfo

Methods inherited from interface io.micronaut.cache.SyncCache

get, get, getExecutorService, putIfAbsent

Constructor Details

RedisConnectionPoolCache

public RedisConnectionPoolCache(DefaultRedisCacheConfiguration defaultRedisCacheConfiguration,
 RedisCacheConfiguration redisCacheConfiguration,
 io.micronaut.core.convert.ConversionService conversionService,
 io.micronaut.context.BeanLocator beanLocator,
 @Named("redisCacheAsyncPool")
 io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>> asyncPool)

Creates a new redis cache for the given arguments.

Parameters:

defaultRedisCacheConfiguration - The default configuration

redisCacheConfiguration - The configuration

conversionService - The conversion service

beanLocator - The bean locator used to discover the redis connection from the configuration

asyncPool - Redis async pool

Method Details

getName

public String getName()

getNativeCache

public io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>> getNativeCache()

get

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

getAll

public <K> @NonNull Map<K,Object> getAll(@NonNull Collection<K> keys)

Resolve the values for the given keys.

Type Parameters:

K - The key type

Parameters:

keys - The cache keys

Returns:

An ordered map containing all requested keys

getAll

public <K,T> @NonNull Map<K,T> getAll(@NonNull Collection<K> keys,
 @NonNull io.micronaut.core.type.Argument<T> requiredType)

Resolve the values for the given keys.

Type Parameters:

K - The key type

T - The value type

Parameters:

keys - The cache keys

requiredType - The required type

Returns:

An ordered map containing all requested keys

putAll

public void putAll(@NonNull Map<?,?> values)

Cache the specified values in bulk.

Parameters:

values - The values to cache

invalidate

public void invalidate(Object key)

invalidateAllKeys

public void invalidateAllKeys(@NonNull Collection<?> keys)

Invalidate the values for the given keys.

Parameters:

keys - The keys to invalidate

invalidateAll

public void invalidateAll()

async

public io.micronaut.cache.AsyncCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>> async()

getValue

protected <T> Optional<T> getValue(io.micronaut.core.type.Argument<T> requiredType,
 byte[] serializedKey)

Get the value based on the parameters.

Specified by:

getValue in class AbstractRedisCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>

Type Parameters:

T - type of the argument

Parameters:

requiredType - requiredType

serializedKey - serializedKey

Returns:

value

putValue

protected <T> void putValue(byte[] serializedKey,
 T value)

Place the value in the cache.

Specified by:

putValue in class AbstractRedisCache<io.lettuce.core.support.AsyncPool<io.lettuce.core.api.StatefulConnection<byte[],byte[]>>>

Type Parameters:

T - type of the value

Parameters:

serializedKey - serializedKey

value - value

close

@PreDestroy
public void close()