Class TextOpDecoder
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.handler.codec.ByteToMessageDecoder
org.infinispan.server.memcached.MemcachedBaseDecoder
org.infinispan.server.memcached.text.TextOpDecoder
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
- Direct Known Subclasses:
TextOpDecoderImpl
- Since:
- 15.0
-
Nested Class Summary
-
Field Summary
FieldsFields inherited from class org.infinispan.server.memcached.MemcachedBaseDecoder
accessLogging, ANONYMOUS, cache, ctx, current, log, principalName, requestStart, server, statistics, statsEnabled, subject, timeService, versionGenerator
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected MemcachedResponse
add
(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet) protected MemcachedResponse
cas
(TextHeader header, byte[] key, byte[] value, int flags, int expiration, long cas, boolean quiet) protected MemcachedResponse
concat
(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet, boolean append) protected MemcachedResponse
delete
(TextHeader header, byte[] key, boolean quiet) protected MemcachedResponse
failedResponse
(Header header, Throwable t) protected MemcachedResponse
flush_all
(TextHeader header, List<byte[]> varargs) protected MemcachedResponse
gat
(TextHeader header, int expiration, List<byte[]> keys, boolean withVersions) protected MemcachedResponse
get
(TextHeader header, List<byte[]> keys, boolean withVersions) void
handlerAdded
(io.netty.channel.ChannelHandlerContext ctx) protected void
handlerRemoved0
(io.netty.channel.ChannelHandlerContext ctx) protected MemcachedResponse
incr
(TextHeader header, byte[] key, byte[] delta, boolean quiet, boolean isIncrement) protected MemcachedResponse
ma
(TextHeader header, byte[] key, List<byte[]> args) protected MemcachedResponse
md
(TextHeader header, byte[] key, List<byte[]> args) protected MemcachedResponse
me
(TextHeader header, byte[] key, List<byte[]> args) protected MemcachedResponse
mg
(TextHeader header, byte[] key, List<byte[]> args) protected MemcachedResponse
mn
(TextHeader header) protected MemcachedResponse
ms
(TextHeader header, byte[] key, byte[] value, List<byte[]> args) protected void
quit
(TextHeader header) protected MemcachedResponse
replace
(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet) protected MemcachedResponse
send
(Header header, CompletionStage<?> response) protected MemcachedResponse
send
(Header header, CompletionStage<?> response, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) protected MemcachedResponse
set
(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet) protected MemcachedResponse
stats
(TextHeader header, List<byte[]> names) protected MemcachedResponse
touch
(TextHeader header, byte[] key, int expiration, boolean quiet) protected MemcachedResponse
version
(TextHeader header) Methods inherited from class org.infinispan.server.memcached.MemcachedBaseDecoder
exceptionCaught, metadata, registerExceptionHandler, resumeRead, statsMap, toMillis, touchMetadata
Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder
actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decode, decodeLast, discardSomeReadBytes, handlerRemoved, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
-
Field Details
-
Constructor Details
-
Method Details
-
get
-
set
protected MemcachedResponse set(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet) -
delete
-
concat
protected MemcachedResponse concat(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet, boolean append) -
replace
protected MemcachedResponse replace(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet) -
add
protected MemcachedResponse add(TextHeader header, byte[] key, byte[] value, int flags, int expiration, boolean quiet) -
cas
protected MemcachedResponse cas(TextHeader header, byte[] key, byte[] value, int flags, int expiration, long cas, boolean quiet) -
touch
-
gat
protected MemcachedResponse gat(TextHeader header, int expiration, List<byte[]> keys, boolean withVersions) -
md
-
ma
-
me
-
mn
-
ms
-
mg
-
flush_all
-
version
-
quit
-
incr
protected MemcachedResponse incr(TextHeader header, byte[] key, byte[] delta, boolean quiet, boolean isIncrement) -
stats
-
handlerAdded
- Specified by:
handlerAdded
in interfaceio.netty.channel.ChannelHandler
- Overrides:
handlerAdded
in classMemcachedBaseDecoder
- Throws:
Exception
-
handlerRemoved0
- Overrides:
handlerRemoved0
in classio.netty.handler.codec.ByteToMessageDecoder
- Throws:
Exception
-
failedResponse
- Specified by:
failedResponse
in classMemcachedBaseDecoder
-
send
- Specified by:
send
in classMemcachedBaseDecoder
-
send
protected MemcachedResponse send(Header header, CompletionStage<?> response, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener) - Specified by:
send
in classMemcachedBaseDecoder
-