com.atlassian.vcache.internal.guava

Class GuavaDirectExternalCache<V>

java.lang.Object

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

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

Type Parameters:

V - the value type.

All Implemented Interfaces:

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

public class GuavaDirectExternalCache<V>
extends AbstractExternalCache<V>
implements com.atlassian.vcache.DirectExternalCache<V>

Guava based implementation of DirectExternalCache.

Since:

1.0.0

Field Summary

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

lockTimeout, name

Constructor Summary

Constructors

Constructor and Description
GuavaDirectExternalCache(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, java.time.Duration lockTimeout)

Method Summary

Modifier and Type	Method and Description
protected AbstractExternalCacheRequestContext<V>	ensureCacheContext()
java.util.concurrent.CompletionStage<java.util.Optional<V>>	get(java.lang.String internalKey)
java.util.concurrent.CompletionStage<V>	get(java.lang.String internalKey, java.util.function.Supplier<V> supplier)
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,V>>	getBulk(java.util.function.Function<java.util.Set<java.lang.String>,java.util.Map<java.lang.String,V>> factory, java.lang.Iterable<java.lang.String> internalKeys)
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.util.Optional<V>>>	getBulk(java.lang.Iterable<java.lang.String> internalKeys)
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.util.Optional<com.atlassian.vcache.IdentifiedValue<V>>>>	getBulkIdentified(java.lang.Iterable<java.lang.String> internalKeys)
java.util.concurrent.CompletionStage<java.util.Optional<com.atlassian.vcache.IdentifiedValue<V>>>	getIdentified(java.lang.String internalKey)
java.util.concurrent.CompletionStage<com.atlassian.vcache.IdentifiedValue<V>>	getIdentified(java.lang.String internalKey, java.util.function.Supplier<V> supplier)
protected org.slf4j.Logger	getLogger()
protected com.atlassian.vcache.ExternalCacheException	mapException(java.lang.Exception ex)
java.util.concurrent.CompletionStage<java.lang.Boolean>	put(java.lang.String internalKey, V value, com.atlassian.vcache.PutPolicy policy)
java.util.concurrent.CompletionStage<java.lang.Void>	remove(java.lang.Iterable<java.lang.String> internalKeys)
java.util.concurrent.CompletionStage<java.lang.Void>	removeAll()
java.util.concurrent.CompletionStage<java.lang.Boolean>	removeIf(java.lang.String internalKey, com.atlassian.vcache.CasIdentifier casId)
java.util.concurrent.CompletionStage<java.lang.Boolean>	replaceIf(java.lang.String internalKey, com.atlassian.vcache.CasIdentifier casId, V newValue)

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.DirectExternalCache

getBulkIdentified

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

GuavaDirectExternalCache

public GuavaDirectExternalCache(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,
                                java.time.Duration lockTimeout)

Method Detail

get

public java.util.concurrent.CompletionStage<java.util.Optional<V>> get(java.lang.String internalKey)

Specified by:

get in interface com.atlassian.vcache.ExternalCache<V>

get

public java.util.concurrent.CompletionStage<V> get(java.lang.String internalKey,
                                                   java.util.function.Supplier<V> supplier)

Specified by:

get in interface com.atlassian.vcache.ExternalCache<V>

getIdentified

public java.util.concurrent.CompletionStage<java.util.Optional<com.atlassian.vcache.IdentifiedValue<V>>> getIdentified(java.lang.String internalKey)

Specified by:

getIdentified in interface com.atlassian.vcache.DirectExternalCache<V>

getIdentified

public java.util.concurrent.CompletionStage<com.atlassian.vcache.IdentifiedValue<V>> getIdentified(java.lang.String internalKey,
                                                                                                   java.util.function.Supplier<V> supplier)

Specified by:

getIdentified in interface com.atlassian.vcache.DirectExternalCache<V>

getBulk

public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.util.Optional<V>>> getBulk(java.lang.Iterable<java.lang.String> internalKeys)

Specified by:

getBulk in interface com.atlassian.vcache.ExternalCache<V>

getBulk

public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,V>> getBulk(java.util.function.Function<java.util.Set<java.lang.String>,java.util.Map<java.lang.String,V>> factory,
                                                                                       java.lang.Iterable<java.lang.String> internalKeys)

Specified by:

getBulk in interface com.atlassian.vcache.ExternalCache<V>

getBulkIdentified

public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.util.Optional<com.atlassian.vcache.IdentifiedValue<V>>>> getBulkIdentified(java.lang.Iterable<java.lang.String> internalKeys)

Specified by:

getBulkIdentified in interface com.atlassian.vcache.DirectExternalCache<V>

put

public java.util.concurrent.CompletionStage<java.lang.Boolean> put(java.lang.String internalKey,
                                                                   V value,
                                                                   com.atlassian.vcache.PutPolicy policy)

Specified by:

put in interface com.atlassian.vcache.ExternalWriteOperationsUnbuffered<V>

removeIf

public java.util.concurrent.CompletionStage<java.lang.Boolean> removeIf(java.lang.String internalKey,
                                                                        com.atlassian.vcache.CasIdentifier casId)

Specified by:

removeIf in interface com.atlassian.vcache.DirectExternalCache<V>

replaceIf

public java.util.concurrent.CompletionStage<java.lang.Boolean> replaceIf(java.lang.String internalKey,
                                                                         com.atlassian.vcache.CasIdentifier casId,
                                                                         V newValue)

Specified by:

replaceIf in interface com.atlassian.vcache.DirectExternalCache<V>

remove

public java.util.concurrent.CompletionStage<java.lang.Void> remove(java.lang.Iterable<java.lang.String> internalKeys)

Specified by:

remove in interface com.atlassian.vcache.ExternalWriteOperationsUnbuffered<V>

removeAll

public java.util.concurrent.CompletionStage<java.lang.Void> removeAll()

Specified by:

removeAll in interface com.atlassian.vcache.ExternalWriteOperationsUnbuffered<V>

ensureCacheContext

protected AbstractExternalCacheRequestContext<V> ensureCacheContext()

Specified by:

ensureCacheContext in class AbstractExternalCache<V>

mapException

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

Specified by:

mapException in class AbstractExternalCache<V>

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractExternalCache<V>