public class Decoder10$ extends AbstractVersionedDecoder implements ServerConstants, Log
| Modifier and Type | Field and Description |
|---|---|
static Decoder10$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
| Constructor and Description |
|---|
Decoder10$() |
| Modifier and Type | Method and Description |
|---|---|
ErrorResponse |
createErrorResponse(HotRodHeader h,
Throwable t)
Create an error response based on the Throwable instance received.
|
Object |
createGetResponse(HotRodHeader h,
CacheEntry entry)
Create a response for get a request.
|
Object |
createNotExecutedResponse(HotRodHeader header,
byte[] prev)
Create a response indicating the the operation could not be executed.
|
Object |
createNotExistResponse(HotRodHeader header)
Create a response indicating that the key, which the message tried to operate on, did not exist.
|
Object |
createStatsResponse(HotRodHeader h,
Stats cacheStats,
NettyTransport t)
Create a response for the stats command.
|
Object |
createSuccessResponse(HotRodHeader header,
byte[] prev)
Create a successful response.
|
Object |
customReadHeader(HotRodHeader h,
org.jboss.netty.buffer.ChannelBuffer buffer,
AdvancedCache<byte[],byte[]> cache)
Handle a protocol specific header reading.
|
Object |
customReadKey(HotRodHeader h,
org.jboss.netty.buffer.ChannelBuffer buffer,
AdvancedCache<byte[],byte[]> cache,
scala.collection.Seq<QueryFacade> queryFacades)
Handle a protocol specific key reading.
|
Object |
customReadValue(HotRodHeader header,
org.jboss.netty.buffer.ChannelBuffer buffer,
AdvancedCache<byte[],byte[]> cache)
Handle a protocol specific value reading.
|
GetWithMetadataResponse |
getKeyMetadata(HotRodHeader h,
byte[] k,
AdvancedCache<byte[],byte[]> cache) |
AdvancedCache<byte[],byte[]> |
getOptimizedCache(HotRodHeader h,
AdvancedCache<byte[],byte[]> c)
Get an optimized cache instance depending on the operation parameters.
|
boolean |
readHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
byte version,
long messageId,
HotRodHeader header)
Having read the message's Id, read the rest of Hot Rod header from the given buffer and return it.
|
scala.Tuple2<byte[],Object> |
readKey(HotRodHeader h,
org.jboss.netty.buffer.ChannelBuffer buffer)
Read the key to operate on from the message.
|
scala.Tuple2<RequestParameters,Object> |
readParameters(HotRodHeader header,
org.jboss.netty.buffer.ChannelBuffer buffer)
Read the parameters of the operation, if present.
|
scala.Enumeration.Value |
toResponse(scala.Enumeration.Value request) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitEXPIRATION_DEFAULT, EXPIRATION_NONElog, logErrorDetectingCrashedMember, logUnableToUpdateView, logViewNullWhileDetectingCrashedMemberdebug, debug, debug, debug, debug, debugf, error, info, info, isDebugEnabled, isTraceEnabled, logChannelStillBound, logChannelStillConnected, logErrorBeforeReadingRequest, logExceptionReported, logPostingShutdownRequest, logServerDidNotClose, logServerDidNotUnbind, logSettingMasterThreadsNotSupported, logStartWithArgs, trace, trace, trace, trace, tracef, warnpublic static final Decoder10$ MODULE$
public boolean readHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
byte version,
long messageId,
HotRodHeader header)
AbstractVersionedDecoderreadHeader in class AbstractVersionedDecoderpublic scala.Tuple2<byte[],Object> readKey(HotRodHeader h, org.jboss.netty.buffer.ChannelBuffer buffer)
AbstractVersionedDecoderreadKey in class AbstractVersionedDecoderpublic scala.Tuple2<RequestParameters,Object> readParameters(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer)
AbstractVersionedDecoderreadParameters in class AbstractVersionedDecoderpublic Object createSuccessResponse(HotRodHeader header, byte[] prev)
AbstractVersionedDecodercreateSuccessResponse in class AbstractVersionedDecoderpublic Object createNotExecutedResponse(HotRodHeader header, byte[] prev)
AbstractVersionedDecodercreateNotExecutedResponse in class AbstractVersionedDecoderpublic Object createNotExistResponse(HotRodHeader header)
AbstractVersionedDecodercreateNotExistResponse in class AbstractVersionedDecoderpublic Object createGetResponse(HotRodHeader h, CacheEntry entry)
AbstractVersionedDecodercreateGetResponse in class AbstractVersionedDecoderpublic Object customReadHeader(HotRodHeader h, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache)
AbstractVersionedDecodercustomReadHeader in class AbstractVersionedDecoderpublic Object customReadKey(HotRodHeader h, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache, scala.collection.Seq<QueryFacade> queryFacades)
AbstractVersionedDecodercustomReadKey in class AbstractVersionedDecoderpublic GetWithMetadataResponse getKeyMetadata(HotRodHeader h, byte[] k, AdvancedCache<byte[],byte[]> cache)
public Object customReadValue(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache)
AbstractVersionedDecodercustomReadValue in class AbstractVersionedDecoderpublic Object createStatsResponse(HotRodHeader h, Stats cacheStats, NettyTransport t)
AbstractVersionedDecodercreateStatsResponse in class AbstractVersionedDecoderpublic ErrorResponse createErrorResponse(HotRodHeader h, Throwable t)
AbstractVersionedDecodercreateErrorResponse in class AbstractVersionedDecoderpublic AdvancedCache<byte[],byte[]> getOptimizedCache(HotRodHeader h, AdvancedCache<byte[],byte[]> c)
AbstractVersionedDecodergetOptimizedCache in class AbstractVersionedDecoderpublic scala.Enumeration.Value toResponse(scala.Enumeration.Value request)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.