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

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