Class CacheResourceV2

java.lang.Object

org.infinispan.rest.resources.BaseCacheResource

org.infinispan.rest.resources.CacheResourceV2

All Implemented Interfaces:

ResourceHandler

Direct Known Subclasses:

CacheResourceV3

public class CacheResourceV2
extends BaseCacheResource
implements ResourceHandler

REST resource to manage the caches.

Since:

10.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CacheResourceV2.BaseCacheListener
static class	CacheResourceV2.StatefulCacheListener
static class	CacheResourceV2.StatelessCacheListener

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.infinispan.registry.InternalCacheRegistry	internalCacheRegistry
protected static final String	MIGRATOR_NAME
protected final ParserRegistry	parserRegistry
protected final ServerStateManager	serverStateManager
protected static final int	STREAM_BATCH_SIZE

Constructor Summary

Constructors

Constructor	Description
CacheResourceV2(InvocationHelper invocationHelper, InfinispanTelemetry telemetryService)

Method Summary

Modifier and Type	Method	Description
protected CompletionStage<RestResponse>	addSourceConnection(RestRequest request)
protected CompletionStage<RestResponse>	assignAlias(RestRequest request)
protected CompletionStage<RestResponse>	cacheExists(RestRequest request)
protected CompletionStage<RestResponse>	compare(RestRequest request)
protected CompletionStage<RestResponse>	convert(RestRequest request)
protected CompletionStage<RestResponse>	deleteSourceConnection(RestRequest request)
protected CompletionStage<RestResponse>	getAllDetails(RestRequest request)
protected CompletionStage<RestResponse>	getCacheAvailability(RestRequest request)
protected CompletionStage<RestResponse>	getCacheConfig(RestRequest request)
protected CompletionStage<RestResponse>	getCacheConfigMutableAttribute(RestRequest request)
protected CompletionStage<RestResponse>	getCacheConfigMutableAttributes(RestRequest request)
protected CompletionStage<RestResponse>	getCacheDistribution(RestRequest request)
protected CompletionStage<RestResponse>	getCacheHealth(RestRequest request)
protected CompletionStage<RestResponse>	getCacheNames(RestRequest request)
protected CompletionStage<RestResponse>	getCacheNamesPerRole(RestRequest request)
protected CompletionStage<RestResponse>	getCaches(RestRequest request)
protected CompletionStage<RestResponse>	getCacheStats(RestRequest request)
protected RestResponse	getDetailResponse(RestRequest request, Cache<?,?> cache, boolean pretty)
Invocations	getInvocations()	Return the Invocations handled by this ResourceHandler.
protected CompletionStage<RestResponse>	getKeyDistribution(RestRequest request)
protected CompletionStage<RestResponse>	getSize(RestRequest request)
protected CompletionStage<RestResponse>	getSourceConnection(RestRequest request)
protected CompletionStage<RestResponse>	hasSourceConnections(RestRequest request)
protected CompletionStage<RestResponse>	reinitializeCache(RestRequest request)
protected CompletionStage<RestResponse>	removeCache(RestRequest request)
protected CompletionStage<RestResponse>	resetCacheStats(RestRequest request)
protected CompletionStage<RestResponse>	setCacheAvailability(RestRequest request)
protected CompletionStage<RestResponse>	setCacheConfigMutableAttribute(RestRequest request)
protected CompletionStage<RestResponse>	setRebalancing(boolean enable, RestRequest request)
protected CompletionStage<RestResponse>	streamEntries(RestRequest request)
protected CompletionStage<RestResponse>	streamKeys(RestRequest request)
protected CompletionStage<RestResponse>	syncData(RestRequest request)

Methods inherited from class BaseCacheResource

keyDistribution, putValueToCache

Methods inherited from class Object

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

Field Details

STREAM_BATCH_SIZE

protected static final int STREAM_BATCH_SIZE

See Also:

• Constant Field Values

MIGRATOR_NAME

protected static final String MIGRATOR_NAME

See Also:

• Constant Field Values

parserRegistry

protected final ParserRegistry parserRegistry

internalCacheRegistry

protected final org.infinispan.registry.InternalCacheRegistry internalCacheRegistry

serverStateManager

protected final ServerStateManager serverStateManager

Constructor Details

CacheResourceV2

public CacheResourceV2(InvocationHelper invocationHelper,
 InfinispanTelemetry telemetryService)

Method Details

getInvocations

public Invocations getInvocations()

Description copied from interface: ResourceHandler

Return the Invocations handled by this ResourceHandler.

Specified by:

getInvocations in interface ResourceHandler

getCaches

protected CompletionStage<RestResponse> getCaches(RestRequest request)

getSourceConnection

protected CompletionStage<RestResponse> getSourceConnection(RestRequest request)

hasSourceConnections

protected CompletionStage<RestResponse> hasSourceConnections(RestRequest request)

deleteSourceConnection

protected CompletionStage<RestResponse> deleteSourceConnection(RestRequest request)

addSourceConnection

protected CompletionStage<RestResponse> addSourceConnection(RestRequest request)

syncData

protected CompletionStage<RestResponse> syncData(RestRequest request)

convert

protected CompletionStage<RestResponse> convert(RestRequest request)

compare

protected CompletionStage<RestResponse> compare(RestRequest request)

streamKeys

protected CompletionStage<RestResponse> streamKeys(RestRequest request)

streamEntries

protected CompletionStage<RestResponse> streamEntries(RestRequest request)

removeCache

protected CompletionStage<RestResponse> removeCache(RestRequest request)

cacheExists

protected CompletionStage<RestResponse> cacheExists(RestRequest request)

getCacheStats

protected CompletionStage<RestResponse> getCacheStats(RestRequest request)

resetCacheStats

protected CompletionStage<RestResponse> resetCacheStats(RestRequest request)

getCacheDistribution

protected CompletionStage<RestResponse> getCacheDistribution(RestRequest request)

getKeyDistribution

protected CompletionStage<RestResponse> getKeyDistribution(RestRequest request)

getAllDetails

protected CompletionStage<RestResponse> getAllDetails(RestRequest request)

getDetailResponse

protected RestResponse getDetailResponse(RestRequest request,
 Cache<?,?> cache,
 boolean pretty)

getCacheConfig

protected CompletionStage<RestResponse> getCacheConfig(RestRequest request)

getCacheAvailability

protected CompletionStage<RestResponse> getCacheAvailability(RestRequest request)

setCacheAvailability

protected CompletionStage<RestResponse> setCacheAvailability(RestRequest request)

getCacheConfigMutableAttributes

protected CompletionStage<RestResponse> getCacheConfigMutableAttributes(RestRequest request)

getCacheConfigMutableAttribute

protected CompletionStage<RestResponse> getCacheConfigMutableAttribute(RestRequest request)

setCacheConfigMutableAttribute

protected CompletionStage<RestResponse> setCacheConfigMutableAttribute(RestRequest request)

assignAlias

protected CompletionStage<RestResponse> assignAlias(RestRequest request)

getSize

protected CompletionStage<RestResponse> getSize(RestRequest request)

getCacheNames

protected CompletionStage<RestResponse> getCacheNames(RestRequest request)
                                               throws RestResponseException

Throws:

RestResponseException

getCacheHealth

protected CompletionStage<RestResponse> getCacheHealth(RestRequest request)
                                                throws RestResponseException

Throws:

RestResponseException

setRebalancing

protected CompletionStage<RestResponse> setRebalancing(boolean enable,
 RestRequest request)

reinitializeCache

protected CompletionStage<RestResponse> reinitializeCache(RestRequest request)

getCacheNamesPerRole

protected CompletionStage<RestResponse> getCacheNamesPerRole(RestRequest request)
                                                      throws RestResponseException

Throws:

RestResponseException