com.atlassian.vcache.internal.guava

Class GuavaStableReadExternalCache<V>

java.lang.Object

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

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

com.atlassian.vcache.internal.guava.GuavaStableReadExternalCache<V>

Type Parameters:

V - the value type

All Implemented Interfaces:

com.atlassian.vcache.ExternalCache<V>, com.atlassian.vcache.ExternalWriteOperationsUnbuffered<V>, com.atlassian.vcache.StableReadExternalCache<V>, com.atlassian.vcache.VCache

public class GuavaStableReadExternalCache<V>
extends AbstractStableReadExternalCache<V>

Guava implementation of StableReadExternalCache.

Since:

1.0.0

Field Summary

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

metricsRecorder

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

lockTimeout, name

Constructor Summary

Constructors

Constructor and Description

GuavaStableReadExternalCache(java.lang.String name, com.google.common.cache.Cache<java.lang.String,IdentifiedData> delegate, java.util.function.Supplier<com.atlassian.vcache.internal.RequestContext> contextSupplier, ExternalCacheKeyGenerator keyGenerator, java.util.Optional<com.atlassian.marshalling.api.MarshallingPair<V>> valueMarshalling, MetricsRecorder metricsRecorder, java.time.Duration lockTimeout)

Method Summary

Modifier and Type	Method and Description
protected java.util.Optional<V>	directGet(java.lang.String externalKey)
protected java.util.Map<java.lang.String,java.util.Optional<V>>	directGetBulk(java.util.Set<java.lang.String> externalKeys)
protected AbstractExternalCacheRequestContext<V>	ensureCacheContext()
protected org.slf4j.Logger	getLogger()
protected V	handleCreation(java.lang.String internalKey, V candidateValue)
protected boolean	internalPut(java.lang.String internalKey, V value, com.atlassian.vcache.PutPolicy policy)
protected void	internalRemove(java.lang.Iterable<java.lang.String> internalKeys)
protected void	internalRemoveAll()
protected com.atlassian.vcache.ExternalCacheException	mapException(java.lang.Exception ex)

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

get, get, getBulk, getBulk, put, remove, removeAll

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

getName, 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

GuavaStableReadExternalCache

public GuavaStableReadExternalCache(java.lang.String name,
                                    com.google.common.cache.Cache<java.lang.String,IdentifiedData> delegate,
                                    java.util.function.Supplier<com.atlassian.vcache.internal.RequestContext> contextSupplier,
                                    ExternalCacheKeyGenerator keyGenerator,
                                    java.util.Optional<com.atlassian.marshalling.api.MarshallingPair<V>> valueMarshalling,
                                    MetricsRecorder metricsRecorder,
                                    java.time.Duration lockTimeout)

Method Detail

internalPut

protected boolean internalPut(java.lang.String internalKey,
                              V value,
                              com.atlassian.vcache.PutPolicy policy)

Specified by:

internalPut in class AbstractStableReadExternalCache<V>

internalRemove

protected void internalRemove(java.lang.Iterable<java.lang.String> internalKeys)

Specified by:

internalRemove in class AbstractStableReadExternalCache<V>

internalRemoveAll

protected void internalRemoveAll()

Specified by:

internalRemoveAll in class AbstractStableReadExternalCache<V>

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractExternalCache<V>

ensureCacheContext

protected AbstractExternalCacheRequestContext<V> ensureCacheContext()

Specified by:

ensureCacheContext in class AbstractExternalCache<V>

handleCreation

protected V handleCreation(java.lang.String internalKey,
                           V candidateValue)
                    throws java.util.concurrent.ExecutionException,
                           java.lang.InterruptedException

Specified by:

handleCreation in class AbstractStableReadExternalCache<V>

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

mapException

protected final com.atlassian.vcache.ExternalCacheException mapException(java.lang.Exception ex)

Specified by:

mapException in class AbstractExternalCache<V>

directGet

protected final java.util.Optional<V> directGet(java.lang.String externalKey)

Specified by:

directGet in class AbstractStableReadExternalCache<V>

directGetBulk

protected final java.util.Map<java.lang.String,java.util.Optional<V>> directGetBulk(java.util.Set<java.lang.String> externalKeys)

Specified by:

directGetBulk in class AbstractStableReadExternalCache<V>