Package org.infinispan.stats.topK

Class CacheUsageInterceptor

java.lang.Object

org.infinispan.interceptors.BaseAsyncInterceptor

org.infinispan.interceptors.DDAsyncInterceptor

org.infinispan.interceptors.BaseCustomAsyncInterceptor

org.infinispan.stats.topK.CacheUsageInterceptor

All Implemented Interfaces:

org.infinispan.commands.Visitor, AsyncInterceptor

public class CacheUsageInterceptor
extends BaseCustomAsyncInterceptor

Intercepts the VisitableCommands to calculate the corresponding top-key values.

Since:

6.0

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_TOP_KEY

Fields inherited from class org.infinispan.interceptors.BaseCustomAsyncInterceptor

cache, embeddedCacheManager

Fields inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

cacheConfiguration

Constructor Summary

Constructors

Constructor	Description
CacheUsageInterceptor()

Method Summary

Modifier and Type	Method	Description
int	getCapacity()
Map<String,Long>	getLocalTopGets()
Map<String,Long>	getLocalTopPuts()
Map<String,Long>	getNLocalTopGets(int n)
Map<String,Long>	getNLocalTopPuts(int n)
Map<String,Long>	getNRemoteTopGets(int n)
Map<String,Long>	getNRemoteTopPuts(int n)
Map<String,Long>	getNTopContendedKeys(int n)
Map<String,Long>	getNTopLockedKeys(int n)
Map<String,Long>	getNTopLockFailedKeys(int n)
Map<String,Long>	getNTopWriteSkewFailedKeys(int n)
Map<String,Long>	getRemoteTopGets()
Map<String,Long>	getRemoteTopPuts()
Map<String,Long>	getTopContendedKeys()
Map<String,Long>	getTopLockedKeys()
Map<String,Long>	getTopLockFailedKeys()
Map<String,Long>	getTopWriteSkewFailedKeys()
void	resetStatistics()
void	setStatisticsEnabled(boolean enabled)
void	setTopKValue(int n)
protected void	start()
protected void	stop()
Object	visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx, org.infinispan.commands.tx.PrepareCommand command)
Object	visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)

Methods inherited from class org.infinispan.interceptors.DDAsyncInterceptor

handleDefault, visitClearCommand, visitCommand, visitCommitCommand, visitComputeCommand, visitComputeIfAbsentCommand, visitDistributedExecuteCommand, visitEntrySetCommand, visitEvictCommand, visitGetCacheEntryCommand, visitGetKeysInGroupCommand, visitInvalidateCommand, visitInvalidateL1Command, visitKeySetCommand, visitLockControlCommand, visitPutMapCommand, visitReadOnlyKeyCommand, visitReadOnlyManyCommand, visitReadWriteKeyCommand, visitReadWriteKeyValueCommand, visitReadWriteManyCommand, visitReadWriteManyEntriesCommand, visitRemoveCommand, visitReplaceCommand, visitRollbackCommand, visitSizeCommand, visitUnknownCommand, visitWriteOnlyKeyCommand, visitWriteOnlyKeyValueCommand, visitWriteOnlyManyCommand, visitWriteOnlyManyEntriesCommand

Methods inherited from class org.infinispan.interceptors.BaseAsyncInterceptor

asyncInvokeNext, asyncInvokeNext, asyncInvokeNext, asyncValue, delayedValue, delayedValue, invokeNext, invokeNextAndExceptionally, invokeNextAndFinally, invokeNextAndHandle, invokeNextThenAccept, invokeNextThenApply, isSuccessfullyDone, makeStage, setNextInterceptor, valueOrException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.Visitor

visitApplyDeltaCommand, visitRemoveExpiredCommand

Field Detail

DEFAULT_TOP_KEY

public static final int DEFAULT_TOP_KEY

See Also:

Constant Field Values

Constructor Detail

CacheUsageInterceptor

public CacheUsageInterceptor()

Method Detail

visitGetKeyValueCommand

public Object visitGetKeyValueCommand(InvocationContext ctx,
                                      org.infinispan.commands.read.GetKeyValueCommand command)
                               throws Throwable

Specified by:

visitGetKeyValueCommand in interface org.infinispan.commands.Visitor

Overrides:

visitGetKeyValueCommand in class DDAsyncInterceptor

Throws:

Throwable

visitGetAllCommand

public Object visitGetAllCommand(InvocationContext ctx,
                                 org.infinispan.commands.read.GetAllCommand command)
                          throws Throwable

Specified by:

visitGetAllCommand in interface org.infinispan.commands.Visitor

Overrides:

visitGetAllCommand in class DDAsyncInterceptor

Throws:

Throwable

visitPutKeyValueCommand

public Object visitPutKeyValueCommand(InvocationContext ctx,
                                      org.infinispan.commands.write.PutKeyValueCommand command)
                               throws Throwable

Specified by:

visitPutKeyValueCommand in interface org.infinispan.commands.Visitor

Overrides:

visitPutKeyValueCommand in class DDAsyncInterceptor

Throws:

Throwable

visitPrepareCommand

public Object visitPrepareCommand(org.infinispan.context.impl.TxInvocationContext ctx,
                                  org.infinispan.commands.tx.PrepareCommand command)
                           throws Throwable

Specified by:

visitPrepareCommand in interface org.infinispan.commands.Visitor

Overrides:

visitPrepareCommand in class DDAsyncInterceptor

Throws:

Throwable

resetStatistics

public void resetStatistics()

setTopKValue

public void setTopKValue(int n)

getCapacity

public int getCapacity()

getRemoteTopGets

public Map<String,Long> getRemoteTopGets()

getNRemoteTopGets

public Map<String,Long> getNRemoteTopGets(int n)

getLocalTopGets

public Map<String,Long> getLocalTopGets()

getNLocalTopGets

public Map<String,Long> getNLocalTopGets(int n)

getRemoteTopPuts

public Map<String,Long> getRemoteTopPuts()

getNRemoteTopPuts

public Map<String,Long> getNRemoteTopPuts(int n)

getLocalTopPuts

public Map<String,Long> getLocalTopPuts()

getNLocalTopPuts

public Map<String,Long> getNLocalTopPuts(int n)

getTopLockedKeys

public Map<String,Long> getTopLockedKeys()

getNTopLockedKeys

public Map<String,Long> getNTopLockedKeys(int n)

getTopContendedKeys

public Map<String,Long> getTopContendedKeys()

getNTopContendedKeys

public Map<String,Long> getNTopContendedKeys(int n)

getTopLockFailedKeys

public Map<String,Long> getTopLockFailedKeys()

getNTopLockFailedKeys

public Map<String,Long> getNTopLockFailedKeys(int n)

getTopWriteSkewFailedKeys

public Map<String,Long> getTopWriteSkewFailedKeys()

getNTopWriteSkewFailedKeys

public Map<String,Long> getNTopWriteSkewFailedKeys(int n)

setStatisticsEnabled

public void setStatisticsEnabled(boolean enabled)

start

protected void start()

Overrides:

start in class BaseCustomAsyncInterceptor

stop

protected void stop()

Overrides:

stop in class BaseCustomAsyncInterceptor