Package org.infinispan.rest.cachemanager

Class RestCacheManager<V>

java.lang.Object

org.infinispan.rest.cachemanager.RestCacheManager<V>

public class RestCacheManager<V>
extends java.lang.Object

Manages caches instances used during rest requests.

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.infinispan.rest.logging.Log	logger

Constructor Summary

Constructors

Constructor	Description
RestCacheManager(EmbeddedCacheManager instance, java.util.function.Predicate<? super java.lang.String> isCacheIgnored)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getBackupOwners(java.lang.String cacheName, java.lang.Object key, RestRequest restRequest)
AdvancedCache<java.lang.Object,V>	getCache(java.lang.String name, MediaType keyContentType, MediaType valueContentType, RestRequest request)
AdvancedCache<java.lang.Object,V>	getCache(java.lang.String name, RestRequest restRequest)
java.util.Collection<java.lang.String>	getCacheNames()
EmbeddedCacheManager	getInstance()
java.util.concurrent.CompletionStage<CacheEntry<java.lang.Object,V>>	getInternalEntry(java.lang.String cacheName, java.lang.Object key, MediaType keyContentType, MediaType mediaType, RestRequest request)
java.lang.String	getNodeName()
java.lang.String	getPrimaryOwner(java.lang.String cacheName, java.lang.Object key, RestRequest restRequest)
java.util.concurrent.CompletionStage<CacheEntry<java.lang.Object,V>>	getPrivilegedInternalEntry(AdvancedCache<java.lang.Object,V> cache, java.lang.Object key, boolean skipListener)
java.lang.String	getServerAddress()
MediaType	getValueConfiguredFormat(java.lang.String cacheName, RestRequest restRequest)
java.util.concurrent.CompletionStage<V>	remove(java.lang.String cacheName, java.lang.Object key, MediaType keyContentType, RestRequest restRequest)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.infinispan.rest.logging.Log logger

Constructor Detail

RestCacheManager

public RestCacheManager(EmbeddedCacheManager instance,
                        java.util.function.Predicate<? super java.lang.String> isCacheIgnored)

Method Detail

getCache

public AdvancedCache<java.lang.Object,V> getCache(java.lang.String name,
                                                        MediaType keyContentType,
                                                        MediaType valueContentType,
                                                        RestRequest request)

getCache

public AdvancedCache<java.lang.Object,V> getCache(java.lang.String name,
                                                        RestRequest restRequest)

getCacheNames

public java.util.Collection<java.lang.String> getCacheNames()

getInternalEntry

public java.util.concurrent.CompletionStage<CacheEntry<java.lang.Object,V>> getInternalEntry(java.lang.String cacheName,
                                                                                                   java.lang.Object key,
                                                                                                   MediaType keyContentType,
                                                                                                   MediaType mediaType,
                                                                                                   RestRequest request)

remove

public java.util.concurrent.CompletionStage<V> remove(java.lang.String cacheName,
                                                      java.lang.Object key,
                                                      MediaType keyContentType,
                                                      RestRequest restRequest)

getPrivilegedInternalEntry

public java.util.concurrent.CompletionStage<CacheEntry<java.lang.Object,V>> getPrivilegedInternalEntry(AdvancedCache<java.lang.Object,V> cache,
                                                                                                             java.lang.Object key,
                                                                                                             boolean skipListener)

getValueConfiguredFormat

public MediaType getValueConfiguredFormat(java.lang.String cacheName,
                                          RestRequest restRequest)

getNodeName

public java.lang.String getNodeName()

getServerAddress

public java.lang.String getServerAddress()

getPrimaryOwner

public java.lang.String getPrimaryOwner(java.lang.String cacheName,
                                        java.lang.Object key,
                                        RestRequest restRequest)

getBackupOwners

public java.lang.String getBackupOwners(java.lang.String cacheName,
                                        java.lang.Object key,
                                        RestRequest restRequest)

getInstance

public EmbeddedCacheManager getInstance()

stop

public void stop()