Package io.micronaut.configuration.lettuce.cache

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(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 io.micronaut.configuration.lettuce.cache.AbstractRedisCache

expireAfterAccess, expireAfterWritePolicy, INVALID_REDIS_CONNECTION_MESSAGE, invalidateScanCount, 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)
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()
protected <T> void	putValue(byte[] serializedKey, T value)	Place the value in the cache.

Methods inherited from class io.micronaut.configuration.lettuce.cache.AbstractRedisCache

get, get, getKeysPattern, getRedisKeyAsyncCommands, getRedisKeyCommands, getRedisStringAsyncCommands, getRedisStringCommands, put, putIfAbsent, putValue, serializeKey

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.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,
 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
 @NonNull Object key,
 @NonNull
 @NonNull io.micronaut.core.type.Argument<T> requiredType,
 @NonNull
 @NonNull Supplier<T> supplier)

invalidate

public void invalidate(Object key)

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()