com.atlassian.vcache.internal.core.service

Class AbstractStableReadExternalCache<V>

java.lang.Object

com.atlassian.vcache.internal.core.service.AbstractExternalCache<V>

com.atlassian.vcache.internal.core.service.AbstractNonDirectExternalCache<V>

com.atlassian.vcache.internal.core.service.AbstractStableReadExternalCache<V>

Type Parameters:

V - the value type

All Implemented Interfaces:

ExternalCache<V>, ExternalWriteOperationsUnbuffered<V>, StableReadExternalCache<V>, VCache

Direct Known Subclasses:

GuavaStableReadExternalCache

public abstract class AbstractStableReadExternalCache<V>
extends AbstractNonDirectExternalCache<V>
implements StableReadExternalCache<V>

Provides operations common to StableReadExternalCache instances.

Locking is provided to synchronise the local and remote caches. There are two locking strategies - a cache wide read-write lock and a per-key lock. The cache wide lock provides exclusion for multi-key operations such as removeAll and getBulk. The key lock provides locking for single key get and put whilst honouring the cache lock.

Since:

1.0.0

Field Summary

Fields inherited from class com.atlassian.vcache.internal.core.service.AbstractNonDirectExternalCache

metricsRecorder

Fields inherited from class com.atlassian.vcache.internal.core.service.AbstractExternalCache

name

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractStableReadExternalCache(String name, MetricsRecorder metricsRecorder)

Method Summary

Modifier and Type	Method and Description
protected Map<String,Optional<V>>	checkValuesRecorded(Iterable<String> internalKeys) Checks for values recorded for specified internal keys.
CompletionStage<Optional<V>>	get(String internalKey) Returns a value that is associated with a specified key.
CompletionStage<V>	get(String internalKey, Supplier<V> supplier) Returns a value that may be associated with a specified key.
CompletionStage<Map<String,V>>	getBulk(Function<Set<String>,Map<String,V>> factory, Iterable<String> internalKeys) Returns the values that are associated with the specified keys.
CompletionStage<Map<String,Optional<V>>>	getBulk(Iterable<String> internalKeys) Returns the values that are associated with the specified keys.
protected abstract CompletionStage<Boolean>	internalPut(String internalKey, V value, PutPolicy policy)
protected abstract CompletionStage<Void>	internalRemove(Iterable<String> keys)
protected abstract CompletionStage<Void>	internalRemoveAll()
CompletionStage<Boolean>	put(String internalKey, V value, PutPolicy policy) Puts the value under the specified key using the specified policy.
CompletionStage<Void>	remove(Iterable<String> keys) Remove the entries with the specified keys.
CompletionStage<Void>	removeAll() Remove all entries in the cache.

Methods inherited from class com.atlassian.vcache.internal.core.service.AbstractNonDirectExternalCache

directGet, directGetBulk, handleCreation, handleCreation

Methods inherited from class com.atlassian.vcache.internal.core.service.AbstractExternalCache

ensureCacheContext, getLogger, getName, mapException, perform, perform

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.vcache.ExternalCache

getBulk, getBulk

Methods inherited from interface com.atlassian.vcache.VCache

getName

Methods inherited from interface com.atlassian.vcache.ExternalWriteOperationsUnbuffered

remove

Constructor Detail

AbstractStableReadExternalCache

protected AbstractStableReadExternalCache(String name,
                                          MetricsRecorder metricsRecorder)

Method Detail

checkValuesRecorded

protected final Map<String,Optional<V>> checkValuesRecorded(Iterable<String> internalKeys)

Description copied from class: AbstractNonDirectExternalCache

Checks for values recorded for specified internal keys.

Specified by:

checkValuesRecorded in class AbstractNonDirectExternalCache<V>

get

public final CompletionStage<Optional<V>> get(String internalKey)

Description copied from interface: ExternalCache

Returns a value that is associated with a specified key.

Specified by:

get in interface ExternalCache<V>

Overrides:

get in class AbstractNonDirectExternalCache<V>

Parameters:

internalKey - the key to check.

Returns:

an Optional which may contain the value associated with the key.

get

public final CompletionStage<V> get(String internalKey,
                                    Supplier<V> supplier)

Description copied from interface: ExternalCache

Returns a value that may be associated with a specified key.

Notes:

• If no entry for the specified key exists, then the specified supplier is called to create an entry in the cache, before it is returned.
• The supplier implementation needs to be multi-thread safe as it may be called concurrently if multiple threads call this method.

Specified by:

get in interface ExternalCache<V>

Overrides:

get in class AbstractNonDirectExternalCache<V>

Parameters:

internalKey - the key uniquely identifying the value to be retrieved

supplier - used to generate the value, if one does not exist already for the key. The supplier may not return null.

Returns:

the value associated with the key.

getBulk

public final CompletionStage<Map<String,Optional<V>>> getBulk(Iterable<String> internalKeys)

Description copied from interface: ExternalCache

Returns the values that are associated with the specified keys.

Specified by:

getBulk in interface ExternalCache<V>

Overrides:

getBulk in class AbstractNonDirectExternalCache<V>

Parameters:

internalKeys - the keys to check.

Returns:

A Map that is keyed on the keys specified. Each entry in the Map will have Optional which may contain the value associated with the key.

getBulk

public final CompletionStage<Map<String,V>> getBulk(Function<Set<String>,Map<String,V>> factory,
                                                    Iterable<String> internalKeys)

Description copied from interface: ExternalCache

Returns the values that are associated with the specified keys.

Notes:

• If no entry exists for a key (or keys), then the specified factory is called once using the current thread passing in the missing keys to create the missing entries in the cache, before it is returned.

Specified by:

getBulk in interface ExternalCache<V>

Overrides:

getBulk in class AbstractNonDirectExternalCache<V>

Parameters:

factory - used to generate the values for the keys that do not have entries. The factory must return a map containing a non-null entry for each supplied key.

internalKeys - the keys to retrieve

Returns:

A Map that is keyed on the keys specified. Each entry in the Map will have the value associated with the key.

put

public final CompletionStage<Boolean> put(String internalKey,
                                          V value,
                                          PutPolicy policy)

Description copied from interface: ExternalWriteOperationsUnbuffered

Puts the value under the specified key using the specified policy.

Specified by:

put in interface ExternalWriteOperationsUnbuffered<V>

Parameters:

internalKey - the key to put the data under

value - the value to associate with the key.

policy - the policy to apply

Returns:

whether the entry was put into the cache.

internalPut

protected abstract CompletionStage<Boolean> internalPut(String internalKey,
                                                        V value,
                                                        PutPolicy policy)

remove

public final CompletionStage<Void> remove(Iterable<String> keys)

Description copied from interface: ExternalWriteOperationsUnbuffered

Remove the entries with the specified keys.

Specified by:

remove in interface ExternalWriteOperationsUnbuffered<V>

Parameters:

keys - the keys of the entries to remove.

Returns:

no indication is given as to whether the entries existed before they were deleted

internalRemove

protected abstract CompletionStage<Void> internalRemove(Iterable<String> keys)

removeAll

public CompletionStage<Void> removeAll()

Description copied from interface: ExternalWriteOperationsUnbuffered

Remove all entries in the cache.

Specified by:

removeAll in interface ExternalWriteOperationsUnbuffered<V>

Returns:

no indication is given as to whether entries existed before they were deleted

internalRemoveAll

protected abstract CompletionStage<Void> internalRemoveAll()