Package org.infinispan.server.resp
Class Resp3AuthHandler
java.lang.Object
org.infinispan.server.resp.RespRequestHandler
org.infinispan.server.resp.CacheRespRequestHandler
org.infinispan.server.resp.Resp3AuthHandler
- Direct Known Subclasses:
Resp3Handler
-
Field Summary
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
-
Constructor Summary
ConstructorsModifierConstructorDescriptionResp3AuthHandler
(RespServer server) protected
Resp3AuthHandler
(RespServer server, AdvancedCache<byte[], byte[]> cache) -
Method Summary
Modifier and TypeMethodDescriptionprotected CompletionStage
<RespRequestHandler> actualHandleRequest
(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, 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.boolean
boolean
performAuth
(io.netty.channel.ChannelHandlerContext ctx) performAuth
(io.netty.channel.ChannelHandlerContext ctx, byte[] username, byte[] password) Methods inherited from class org.infinispan.server.resp.CacheRespRequestHandler
cache, setCache, typedCache
Methods inherited from class org.infinispan.server.resp.RespRequestHandler
commandNotFound, handleChannelDisconnect, handleRequest, initializeIfNecessary, myStage, respServer, stageToReturn, stageToReturn, stageToReturn, writer
-
Constructor Details
-
Resp3AuthHandler
-
Resp3AuthHandler
-
-
Method Details
-
actualHandleRequest
protected CompletionStage<RespRequestHandler> actualHandleRequest(io.netty.channel.ChannelHandlerContext ctx, RespCommand command, 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 classRespRequestHandler
- Parameters:
ctx
- Netty context pipeline for this requestcommand
- 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
-
performAuth
public CompletionStage<Boolean> performAuth(io.netty.channel.ChannelHandlerContext ctx, byte[] username, byte[] password) -
performAuth
-
isAuthorized
public boolean isAuthorized() -
canUseCertAuth
public boolean canUseCertAuth()
-