io.micronaut.configuration.lettuce.cache

Class RedisCache

java.lang.Object

io.micronaut.configuration.lettuce.cache.RedisCache

All Implemented Interfaces:

io.micronaut.cache.Cache<io.lettuce.core.api.StatefulConnection<?,?>>, io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>, java.lang.AutoCloseable

@EachBean(value=RedisCacheConfiguration.class)
 @Requires(classes=io.micronaut.cache.SyncCache.class)
public class RedisCache
extends java.lang.Object
implements io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>, java.lang.AutoCloseable

An implementation of SyncCache for Lettuce / Redis.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
RedisCache(DefaultRedisCacheConfiguration defaultRedisCacheConfiguration, RedisCacheConfiguration redisCacheConfiguration, io.micronaut.core.convert.ConversionService<?> conversionService, io.micronaut.context.BeanLocator beanLocator) Creates a new redis cache for the given arguments.

Method Summary

Modifier and Type	Method and Description
io.micronaut.cache.AsyncCache<io.lettuce.core.api.StatefulConnection<?,?>>	async()
void	close()
<T> java.util.Optional<T>	get(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType)
<T> T	get(java.lang.Object key, io.micronaut.core.type.Argument<T> requiredType, java.util.function.Supplier<T> supplier)
protected java.lang.String	getKeysPattern()
java.lang.String	getName()
io.lettuce.core.api.StatefulConnection<?,?>	getNativeCache()
protected <T> java.util.Optional<T>	getValue(io.micronaut.core.type.Argument<T> requiredType, byte[] serializedKey) Get the value based on the parameters.
void	invalidate(java.lang.Object key)
void	invalidateAll()
void	put(java.lang.Object key, java.lang.Object value)
<T> java.util.Optional<T>	putIfAbsent(java.lang.Object key, T value)
protected <T> void	putValue(byte[] serializedKey, T value) Place the value in the cache.
protected byte[]	serializeKey(java.lang.Object key) Serialize the key.

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.SyncCache

get, get, getExecutorService, putIfAbsent

Methods inherited from interface io.micronaut.cache.Cache

getCacheInfo

Constructor Detail

RedisCache

public RedisCache(DefaultRedisCacheConfiguration defaultRedisCacheConfiguration,
                  RedisCacheConfiguration redisCacheConfiguration,
                  io.micronaut.core.convert.ConversionService<?> conversionService,
                  io.micronaut.context.BeanLocator beanLocator)

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

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface io.micronaut.cache.Cache<io.lettuce.core.api.StatefulConnection<?,?>>

getNativeCache

public io.lettuce.core.api.StatefulConnection<?,?> getNativeCache()

Specified by:

getNativeCache in interface io.micronaut.cache.Cache<io.lettuce.core.api.StatefulConnection<?,?>>

get

public <T> java.util.Optional<T> get(java.lang.Object key,
                                     io.micronaut.core.type.Argument<T> requiredType)

Specified by:

get in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

get

public <T> T get(java.lang.Object key,
                 io.micronaut.core.type.Argument<T> requiredType,
                 java.util.function.Supplier<T> supplier)

Specified by:

get in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

putIfAbsent

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

Specified by:

putIfAbsent in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

put

public void put(java.lang.Object key,
                java.lang.Object value)

Specified by:

put in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

invalidate

public void invalidate(java.lang.Object key)

Specified by:

invalidate in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

invalidateAll

public void invalidateAll()

Specified by:

invalidateAll in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

async

public io.micronaut.cache.AsyncCache<io.lettuce.core.api.StatefulConnection<?,?>> async()

Specified by:

async in interface io.micronaut.cache.SyncCache<io.lettuce.core.api.StatefulConnection<?,?>>

getValue

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

Get the value based on the parameters.

Type Parameters:

T - type of the argument

Parameters:

requiredType - requiredType

serializedKey - serializedKey

Returns:

value

getKeysPattern

protected java.lang.String getKeysPattern()

Returns:

The default keys pattern.

putValue

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

Place the value in the cache.

Type Parameters:

T - type of the value

Parameters:

serializedKey - serializedKey

value - value

serializeKey

protected byte[] serializeKey(java.lang.Object key)

Serialize the key.

Parameters:

key - The key

Returns:

bytes of the object

close

@PreDestroy
public void close()

Specified by:

close in interface java.lang.AutoCloseable