Class Resp3Handler

java.lang.Object

org.infinispan.server.resp.RespRequestHandler

org.infinispan.server.resp.CacheRespRequestHandler

org.infinispan.server.resp.Resp3AuthHandler

org.infinispan.server.resp.Resp3Handler

Direct Known Subclasses:

SubscriberHandler

public class Resp3Handler
extends Resp3AuthHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final BlockingManager	blockingManager
protected EmbeddedSetCache<byte[],byte[]>	embeddedSetCache
protected AdvancedCache<byte[],byte[]>	ignorePreviousValueCache
protected EmbeddedJsonCache	jsonCache
protected EmbeddedMultimapListCache<byte[],byte[]>	listMultimap
protected EmbeddedMultimapPairCache<byte[],byte[],byte[]>	mapMultimap
protected final ScheduledExecutorService	scheduler
protected EmbeddedMultimapSortedSetCache<byte[],byte[]>	sortedSetMultimap

Fields inherited from class RespRequestHandler

BYTE_BUF_POOL_ATTRIBUTE_KEY, myStage, respServer, writer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Resp3Handler(Resp3Handler delegate)

Method Summary

Modifier and Type	Method	Description
protected CompletionStage<RespRequestHandler>	actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx, RespCommand type, List<byte[]> arguments)	Handles the RESP request returning a stage that when complete notifies the command has completed as well as providing the request handler for subsequent commands.
void	checkPermission(AuthorizationPermission authorizationPermission)
CompletionStage<RespRequestHandler>	delegate(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, List<byte[]> arguments)
BlockingManager	getBlockingManager()
EmbeddedSetCache<byte[],byte[]>	getEmbeddedSetCache()
EmbeddedMultimapPairCache<byte[],byte[],byte[]>	getHashMapMultimap()
EmbeddedJsonCache	getJsonCache()
EmbeddedMultimapListCache<byte[],byte[]>	getListMultimap()
ScheduledExecutorService	getScheduler()
EmbeddedMultimapSortedSetCache<byte[],byte[]>	getSortedSeMultimap()
AdvancedCache<byte[],byte[]>	ignorePreviousValuesCache()
void	setCache(AdvancedCache<byte[],byte[]> cache)

Methods inherited from class Resp3AuthHandler

canUseCertAuth, isAuthorized, performAuth, performAuth

Methods inherited from class CacheRespRequestHandler

cache, typedCache

Methods inherited from class RespRequestHandler

commandNotFound, handleChannelDisconnect, handleRequest, initializeIfNecessary, myStage, respServer, stageToReturn, stageToReturn, stageToReturn, writer, writer

Methods inherited from class Object

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

Field Details

ignorePreviousValueCache

protected AdvancedCache<byte[],byte[]> ignorePreviousValueCache

listMultimap

protected EmbeddedMultimapListCache<byte[],byte[]> listMultimap

mapMultimap

protected EmbeddedMultimapPairCache<byte[],byte[],byte[]> mapMultimap

embeddedSetCache

protected EmbeddedSetCache<byte[],byte[]> embeddedSetCache

sortedSetMultimap

protected EmbeddedMultimapSortedSetCache<byte[],byte[]> sortedSetMultimap

jsonCache

protected EmbeddedJsonCache jsonCache

scheduler

protected final ScheduledExecutorService scheduler

blockingManager

protected final BlockingManager blockingManager

Constructor Details

Resp3Handler

protected Resp3Handler(Resp3Handler delegate)

Method Details

setCache

public void setCache(AdvancedCache<byte[],byte[]> cache)

Overrides:

setCache in class CacheRespRequestHandler

getJsonCache

public EmbeddedJsonCache getJsonCache()

getListMultimap

public EmbeddedMultimapListCache<byte[],byte[]> getListMultimap()

getHashMapMultimap

public EmbeddedMultimapPairCache<byte[],byte[],byte[]> getHashMapMultimap()

getEmbeddedSetCache

public EmbeddedSetCache<byte[],byte[]> getEmbeddedSetCache()

getSortedSeMultimap

public EmbeddedMultimapSortedSetCache<byte[],byte[]> getSortedSeMultimap()

getScheduler

public ScheduledExecutorService getScheduler()

getBlockingManager

public BlockingManager getBlockingManager()

actualHandleRequest

protected CompletionStage<RespRequestHandler> actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx,
 RespCommand type,
 List<byte[]> arguments)

Description copied from class: RespRequestHandler

Handles the RESP request returning a stage that when complete notifies the command has completed as well as providing the request handler for subsequent commands.

Implementations should never use the ByteBufAllocator in the context. Instead, they should use RespRequestHandler.writer to retrieve a ResponseWriter This ByteBuffer should only have bytes written to it adding up to the size requested. The ByteBuffer itself should never be written to the context or channel and flush should also never be invoked. Failure to do so may cause mis-ordering or responses as requests support pipelining and a ByteBuf may not be sent down stream until later in the pipeline.

Overrides:

actualHandleRequest in class Resp3AuthHandler

Parameters:

ctx - Netty context pipeline for this request

type - The command type

arguments - The remaining arguments to the command

Returns:

stage that when complete returns the new handler to instate. This stage must be completed on the event loop

ignorePreviousValuesCache

public AdvancedCache<byte[],byte[]> ignorePreviousValuesCache()

delegate

public CompletionStage<RespRequestHandler> delegate(io.netty.channel.ChannelHandlerContext ctx,
 RespCommand command,
 List<byte[]> arguments)

checkPermission

public void checkPermission(AuthorizationPermission authorizationPermission)