Package org.ametys.core.cache

Class AbstractCacheManager

java.lang.Object

org.ametys.runtime.plugin.component.AbstractLogEnabled

org.ametys.core.cache.AbstractCacheManager

All Implemented Interfaces:

LogEnabled, RequestListener, Initializable, Component, Contextualizable, Serviceable

Direct Known Subclasses:

GuavaCacheManager

public abstract class AbstractCacheManager
extends AbstractLogEnabled
implements Component, Serviceable, Contextualizable, Initializable, RequestListener

Component that handle all the caches

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	AbstractCacheManager.CacheInfo	Encapsulation of name and description of a cache
static enum	AbstractCacheManager.CacheType	The type of cache

Field Summary

Fields

Modifier and Type	Field	Description
protected Context	_context	Avalon context
protected Map<String,Cache>	_memoryCaches	Map linking id with persistent caches
protected Map<String,List<WeakReference<Cache>>>	_requestCaches	HashMap linking an id with a List of WeakReference of Caches.
protected RequestListenerManager	_requestListenerManager	RequestListener manager
protected Map<String,AbstractCacheManager.CacheInfo>	_requestsCacheInfos	Map linking id with CacheInfo of a request cache
protected Map<String,CacheStats>	_requestsCacheStats	Map linking id with CacheStats of a request cache
static final String	ROLE	Role

Constructor Summary

Constructors

Constructor	Description
AbstractCacheManager()

Method Summary

Modifier and Type	Method	Description
protected abstract <K, V> Cache<K,V>	_createCache(String id, I18nizableText name, I18nizableText description, boolean computableSize, Duration duration, boolean isDispatchable)	Create a new cache
protected void	_createCache(String id, I18nizableText name, I18nizableText description, AbstractCacheManager.CacheType cacheType, boolean computableSize, Duration duration, boolean isDispatchable)	Create a new cache and store it in memoryCache map if it's a MEMORY CacheType, Create a CacheInfo to create the cache later otherwise
void	contextualize(Context context)
void	createMemoryCache(String id, I18nizableText name, I18nizableText description, boolean computableSize, Duration duration)	Create a new cache and store it in memoryCache map if it's a MEMORY CacheType, Create a CacheInfo to create the cache later otherwise
void	createRequestCache(String id, I18nizableText name, I18nizableText description, boolean isDispatchable)	Create a new cache and store it in memoryCache map if it's a MEMORY CacheType, Create a CacheInfo to create the cache later otherwise
<K, V> Cache<K,V>	get(String id)	Get the cache by id.
Map<Pair<String,AbstractCacheManager.CacheType>,List<Cache>>	getAllCaches()	Get all caches classified by Identifier and CacheType.
List<Cache>	getAllMemoryCaches()	Get all the memory caches identified by Id
List<Map<String,Object>>	getCachesAsJSONMap()	Get list of memory caches in JSON format
boolean	hasCache(String id)	Returns true if the cache with given id exists
void	initialize()
void	refreshStats(Request req, String id)	Called whenever a request caches' statistics need to be manually refreshed
void	removeCache(String id, AbstractCacheManager.CacheType cacheType)	Remove the cache identified by the given id.
void	requestEnded(HttpServletRequest req)	Called at the end of the HttpServlet.service() method
void	requestStarted(HttpServletRequest req)	Called at the beginning of the HttpServlet.service() method
List<String>	resetAllMemoryCaches()	Reset all memory caches
List<String>	resetCaches(List<String> ids)	Reset the cache with provided ids
void	service(ServiceManager serviceManager)
boolean	setSize(String id, long size)	set new max size to the cache related to given id

Methods inherited from class org.ametys.runtime.plugin.component.AbstractLogEnabled

getLogger, setLogger

Methods inherited from class java.lang.Object

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

Field Details

ROLE

public static final String ROLE

Role

_memoryCaches

protected Map<String,Cache> _memoryCaches

Map linking id with persistent caches

_requestsCacheInfos

protected Map<String,AbstractCacheManager.CacheInfo> _requestsCacheInfos

Map linking id with CacheInfo of a request cache

_requestsCacheStats

protected Map<String,CacheStats> _requestsCacheStats

Map linking id with CacheStats of a request cache

_requestCaches

protected Map<String,List<WeakReference<Cache>>> _requestCaches

HashMap linking an id with a List of WeakReference of Caches. this mean values can be destroyed by the garbage collector

_context

protected Context _context

Avalon context

_requestListenerManager

protected RequestListenerManager _requestListenerManager

RequestListener manager

Constructor Details

AbstractCacheManager

public AbstractCacheManager()

Method Details

initialize

public void initialize()
                throws Exception

Specified by:

initialize in interface Initializable

Throws:

Exception

service

public void service(ServiceManager serviceManager)
             throws ServiceException

Specified by:

service in interface Serviceable

Throws:

ServiceException

requestEnded

public void requestEnded(HttpServletRequest req)

Description copied from interface: RequestListener

Called at the end of the HttpServlet.service() method

Specified by:

requestEnded in interface RequestListener

Parameters:

req - the processed request

refreshStats

public void refreshStats(Request req,
 String id)

Called whenever a request caches' statistics need to be manually refreshed

Parameters:

req - the processed request

id - the if of the cache to refresh

requestStarted

public void requestStarted(HttpServletRequest req)

Description copied from interface: RequestListener

Called at the beginning of the HttpServlet.service() method

Specified by:

requestStarted in interface RequestListener

Parameters:

req - the request being processed

contextualize

public void contextualize(Context context)
                   throws ContextException

Specified by:

contextualize in interface Contextualizable

Throws:

ContextException

createMemoryCache

public void createMemoryCache(String id,
 I18nizableText name,
 I18nizableText description,
 boolean computableSize,
 Duration duration)
                       throws CacheException

Create a new cache and store it in memoryCache map if it's a MEMORY CacheType, Create a CacheInfo to create the cache later otherwise

Parameters:

id - id of the cache

name - name of the cache

description - description

computableSize - true if the size of the cache can be computed

duration - the length of time after an entry is created that it should be automatically removed. Only used for MEMORY type caches

Throws:

CacheException - if a cache already exists for the id

createRequestCache

public void createRequestCache(String id,
 I18nizableText name,
 I18nizableText description,
 boolean isDispatchable)
                        throws CacheException

Create a new cache and store it in memoryCache map if it's a MEMORY CacheType, Create a CacheInfo to create the cache later otherwise

Parameters:

id - id of the cache

name - name of the cache

description - description

isDispatchable - true if the cache can be transmitted in sub-requests of DispatchGenerator

Throws:

CacheException - if a cache already exists for the id

_createCache

protected void _createCache(String id,
 I18nizableText name,
 I18nizableText description,
 AbstractCacheManager.CacheType cacheType,
 boolean computableSize,
 Duration duration,
 boolean isDispatchable)
                     throws CacheException

Create a new cache and store it in memoryCache map if it's a MEMORY CacheType, Create a CacheInfo to create the cache later otherwise

Parameters:

id - id of the cache

name - name of the cache

description - description

cacheType - type of the cache (REQUEST or MEMORY)

computableSize - true if the size of the cache can be computed

duration - the length of time after an entry is created that it should be automatically removed. Only used for MEMORY type caches

isDispatchable - true if the cache can be transmitted in sub-requests of DispatchGenerator

Throws:

CacheException - if a cache already exists for the id

removeCache

public void removeCache(String id,
 AbstractCacheManager.CacheType cacheType)
                 throws CacheException

Remove the cache identified by the given id.

Parameters:

id - id of the cache

cacheType - type of the cache

Throws:

CacheException - if the cache does not exist for the id and type

get

public <K,
V> Cache<K,V> get(String id)
                     throws CacheException

Get the cache by id. If it's a request cache, create it and store it in request and in _requestCaches map.

Type Parameters:

K - the type of the keys in cache

V - the type of the values in cache

Parameters:

id - id of the cache

Returns:

the cache related to the id

Throws:

CacheException - if no cache exist for the id

getAllMemoryCaches

public List<Cache> getAllMemoryCaches()

Get all the memory caches identified by Id

Returns:

all memory caches

getAllCaches

public Map<Pair<String,AbstractCacheManager.CacheType>,List<Cache>> getAllCaches()

Get all caches classified by Identifier and CacheType. All caches includes all running request caches in any existing request.

Returns:

all cache

getCachesAsJSONMap

public List<Map<String,Object>> getCachesAsJSONMap()

Get list of memory caches in JSON format

Returns:

the memory caches in JSON format

hasCache

public boolean hasCache(String id)

Returns true if the cache with given id exists

Parameters:

id - id of the cache

Returns:

true if the cache with given id exists

setSize

public boolean setSize(String id,
 long size)
                throws CacheException,
UnsupportedOperationException

set new max size to the cache related to given id

Parameters:

id - the id of cache

size - the size of the cache in bytes

Returns:

true if success

Throws:

CacheException - throw CacheException if the key is null or invalid

UnsupportedOperationException - not implemented yet

_createCache

protected abstract <K,
V> Cache<K,V> _createCache(String id,
 I18nizableText name,
 I18nizableText description,
 boolean computableSize,
 Duration duration,
 boolean isDispatchable)

Create a new cache

Type Parameters:

K - Key type of the cache

V - Value type of the cache

Parameters:

id - the id of the cache

name - the name of the cache

description - the description of the cache

computableSize - true if the size of the cache can be computed

duration - the length of time after an entry is created that it should be automatically removed

isDispatchable - true if the cache can be transmitted in sub-requests of DispatchGenerator

Returns:

new cache

resetAllMemoryCaches

public List<String> resetAllMemoryCaches()

Reset all memory caches

Returns:

the list of reseted cache's id

resetCaches

public List<String> resetCaches(List<String> ids)

Reset the cache with provided ids

Parameters:

ids - the list of cache to reset

Returns:

the ids of cache that were actually reseted