com.atlassian.confluence.cache

Class ConfluenceMonitoringCache<K,V>

java.lang.Object

com.atlassian.confluence.cache.ConfluenceMonitoringCache<K,V>

All Implemented Interfaces:

com.atlassian.cache.Cache<K,V>, com.atlassian.cache.ManagedCache, ConfigurableCache<K,V>, ConfluenceCache<K,V>

@Internal
public class ConfluenceMonitoringCache<K,V>
extends Object
implements ConfluenceCache<K,V>

A wrapper for monitoring the performance of Confluence caches. The performance is monitored using the supplied ConfluenceMonitoring instance.

Since:

5.6

Constructor Summary

Constructors

Constructor and Description
ConfluenceMonitoringCache(ConfluenceCache<K,V> cache, ConfluenceMonitoring confluenceMonitoring) Constructs a new instance.

Method Summary

Modifier and Type	Method and Description
void	addListener(@NonNull com.atlassian.cache.CacheEntryListener<K,V> kvCacheEntryListener, boolean b)
void	clear()
boolean	containsKey(K k)
protected Split	createLockSplit()
protected Split	createReadSplit()
protected Split	createSplit(String operation)
protected Split	createUnlockSplit()
protected Split	createWriteSplit()
@Nullable Long	currentExpireAfterAccessMillis()
@Nullable Long	currentExpireAfterWriteMillis()
@Nullable Integer	currentMaxEntries()
V	get(K key)
V	get(K k, com.atlassian.cache.Supplier<? extends V> supplier)
@Nullable com.atlassian.instrumentation.caches.CacheCollector	getCacheCollector()
@NonNull Collection<K>	getKeys()
@NonNull String	getName()
@NonNull SortedMap<com.atlassian.cache.CacheStatisticsKey,Supplier<Long>>	getStatistics()
boolean	isFlushable()
boolean	isLocal()
boolean	isReplicateAsynchronously()
boolean	isReplicateViaCopy()
boolean	isStatisticsEnabled()
void	put(K key, V value)
V	putIfAbsent(K key, V value)
void	remove(K key)
boolean	remove(K key, V value)
void	removeAll()
void	removeListener(@NonNull com.atlassian.cache.CacheEntryListener<K,V> kvCacheEntryListener)
boolean	replace(K key, V oldValue, V newValue)
void	setStatistics(boolean b)
void	setTimeToLive(long timeToLive, TimeUnit timeUnit) Update the time to live.
boolean	updateExpireAfterAccess(long expireAfter, @NonNull TimeUnit timeUnit)
boolean	updateExpireAfterWrite(long expireAfter, @NonNull TimeUnit timeUnit)
boolean	updateMaxEntries(int newValue)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.cache.Cache

getBulk

Constructor Detail

ConfluenceMonitoringCache

public ConfluenceMonitoringCache(ConfluenceCache<K,V> cache,
                                 ConfluenceMonitoring confluenceMonitoring)

Constructs a new instance.

Parameters:

cache - the (Cache) interface to the cache to be monitored

confluenceMonitoring - the ConfluenceMonitoring instance to use for monitoring

Method Detail

get

public V get(K key)

Specified by:

get in interface com.atlassian.cache.Cache<K,V>

get

public V get(K k,
             com.atlassian.cache.Supplier<? extends V> supplier)

Specified by:

get in interface com.atlassian.cache.Cache<K,V>

containsKey

public boolean containsKey(K k)

Specified by:

containsKey in interface com.atlassian.cache.Cache<K,V>

getKeys

public @NonNull Collection<K> getKeys()

Specified by:

getKeys in interface com.atlassian.cache.Cache<K,V>

put

public void put(K key,
                V value)

Specified by:

put in interface com.atlassian.cache.Cache<K,V>

remove

public void remove(K key)

Specified by:

remove in interface com.atlassian.cache.Cache<K,V>

removeAll

public void removeAll()

Specified by:

removeAll in interface com.atlassian.cache.Cache<K,V>

putIfAbsent

public V putIfAbsent(K key,
                     V value)

Specified by:

putIfAbsent in interface com.atlassian.cache.Cache<K,V>

replace

public boolean replace(K key,
                       V oldValue,
                       V newValue)

Specified by:

replace in interface com.atlassian.cache.Cache<K,V>

addListener

public void addListener(@NonNull com.atlassian.cache.CacheEntryListener<K,V> kvCacheEntryListener,
                        boolean b)

Specified by:

addListener in interface com.atlassian.cache.Cache<K,V>

removeListener

public void removeListener(@NonNull com.atlassian.cache.CacheEntryListener<K,V> kvCacheEntryListener)

Specified by:

removeListener in interface com.atlassian.cache.Cache<K,V>

remove

public boolean remove(K key,
                      V value)

Specified by:

remove in interface com.atlassian.cache.Cache<K,V>

clear

public void clear()

Specified by:

clear in interface com.atlassian.cache.ManagedCache

getName

public @NonNull String getName()

Specified by:

getName in interface com.atlassian.cache.Cache<K,V>

Specified by:

getName in interface com.atlassian.cache.ManagedCache

isFlushable

public boolean isFlushable()

Specified by:

isFlushable in interface com.atlassian.cache.ManagedCache

currentMaxEntries

public @Nullable Integer currentMaxEntries()

Specified by:

currentMaxEntries in interface com.atlassian.cache.ManagedCache

updateMaxEntries

public boolean updateMaxEntries(int newValue)

Specified by:

updateMaxEntries in interface com.atlassian.cache.ManagedCache

currentExpireAfterAccessMillis

public @Nullable Long currentExpireAfterAccessMillis()

Specified by:

currentExpireAfterAccessMillis in interface com.atlassian.cache.ManagedCache

updateExpireAfterAccess

public boolean updateExpireAfterAccess(long expireAfter,
                                       @NonNull TimeUnit timeUnit)

Specified by:

updateExpireAfterAccess in interface com.atlassian.cache.ManagedCache

currentExpireAfterWriteMillis

public @Nullable Long currentExpireAfterWriteMillis()

Specified by:

currentExpireAfterWriteMillis in interface com.atlassian.cache.ManagedCache

updateExpireAfterWrite

public boolean updateExpireAfterWrite(long expireAfter,
                                      @NonNull TimeUnit timeUnit)

Specified by:

updateExpireAfterWrite in interface com.atlassian.cache.ManagedCache

isLocal

public boolean isLocal()

Specified by:

isLocal in interface com.atlassian.cache.ManagedCache

isReplicateAsynchronously

public boolean isReplicateAsynchronously()

Specified by:

isReplicateAsynchronously in interface com.atlassian.cache.ManagedCache

isReplicateViaCopy

public boolean isReplicateViaCopy()

Specified by:

isReplicateViaCopy in interface com.atlassian.cache.ManagedCache

isStatisticsEnabled

public boolean isStatisticsEnabled()

Specified by:

isStatisticsEnabled in interface com.atlassian.cache.ManagedCache

setStatistics

public void setStatistics(boolean b)

Specified by:

setStatistics in interface com.atlassian.cache.ManagedCache

getStatistics

public @NonNull SortedMap<com.atlassian.cache.CacheStatisticsKey,Supplier<Long>> getStatistics()

Specified by:

getStatistics in interface com.atlassian.cache.ManagedCache

getCacheCollector

public @Nullable com.atlassian.instrumentation.caches.CacheCollector getCacheCollector()

Specified by:

getCacheCollector in interface com.atlassian.cache.ManagedCache

setTimeToLive

public void setTimeToLive(long timeToLive,
                          TimeUnit timeUnit)

Description copied from interface: ConfigurableCache

Update the time to live. Please note, some implementations cannot store time values smaller than TimeUnit.SECONDS.

Specified by:

setTimeToLive in interface ConfigurableCache<K,V>

Parameters:

timeToLive - value

timeUnit - unit of time

createSplit

protected Split createSplit(String operation)

createReadSplit

protected Split createReadSplit()

createWriteSplit

protected Split createWriteSplit()

createLockSplit

protected Split createLockSplit()

createUnlockSplit

protected Split createUnlockSplit()