Package org.infinispan.server.resp
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
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final BlockingManager
protected EmbeddedSetCache
<byte[], byte[]> protected AdvancedCache
<byte[], byte[]> protected EmbeddedMultimapListCache
<byte[], byte[]> protected EmbeddedMultimapPairCache
<byte[], byte[], byte[]> protected final ScheduledExecutorService
protected EmbeddedMultimapSortedSetCache
<byte[], byte[]> Fields inherited from class org.infinispan.server.resp.CacheRespRequestHandler
cache
Fields inherited from class org.infinispan.server.resp.RespRequestHandler
BYTE_BUF_POOL_ATTRIBUTE_KEY, myStage, respServer, writer
-
Method Summary
Modifier and TypeMethodDescriptionprotected 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) delegate
(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, List<byte[]> arguments) EmbeddedSetCache
<byte[], byte[]> EmbeddedMultimapPairCache
<byte[], byte[], byte[]> EmbeddedMultimapListCache
<byte[], byte[]> EmbeddedMultimapSortedSetCache
<byte[], byte[]> AdvancedCache
<byte[], byte[]> void
setCache
(AdvancedCache<byte[], byte[]> cache) Methods inherited from class org.infinispan.server.resp.Resp3AuthHandler
canUseCertAuth, isAuthorized, performAuth, performAuth
Methods inherited from class org.infinispan.server.resp.CacheRespRequestHandler
cache, typedCache
Methods inherited from class org.infinispan.server.resp.RespRequestHandler
commandNotFound, handleChannelDisconnect, handleRequest, initializeIfNecessary, myStage, respServer, stageToReturn, stageToReturn, stageToReturn, writer
-
Field Details
-
ignorePreviousValueCache
-
listMultimap
-
mapMultimap
-
embeddedSetCache
-
sortedSetMultimap
-
scheduler
-
blockingManager
-
-
Method Details
-
setCache
- Overrides:
setCache
in classCacheRespRequestHandler
-
getListMultimap
-
getHashMapMultimap
-
getEmbeddedSetCache
-
getSortedSeMultimap
-
getScheduler
-
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 aResponseWriter
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 classResp3AuthHandler
- Parameters:
ctx
- Netty context pipeline for this requesttype
- The command typearguments
- 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
-
delegate
public CompletionStage<RespRequestHandler> delegate(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, List<byte[]> arguments) -
checkPermission
-