public class Decoder10 extends AbstractVersionedDecoder implements ServerConstants, Log
Constructor and Description |
---|
Decoder10() |
Modifier and Type | Method and Description |
---|---|
static ErrorResponse |
createErrorResponse(HotRodHeader h,
Throwable t) |
static Object |
createGetResponse(HotRodHeader h,
CacheEntry entry) |
static Object |
createNotExecutedResponse(HotRodHeader header,
byte[] prev) |
static Object |
createNotExistResponse(HotRodHeader header) |
static Object |
createStatsResponse(HotRodHeader h,
Stats cacheStats,
NettyTransport t) |
static Object |
createSuccessResponse(HotRodHeader header,
byte[] prev) |
static Object |
customReadHeader(HotRodHeader h,
org.jboss.netty.buffer.ChannelBuffer buffer,
AdvancedCache<byte[],byte[]> cache) |
static Object |
customReadKey(HotRodHeader h,
org.jboss.netty.buffer.ChannelBuffer buffer,
AdvancedCache<byte[],byte[]> cache,
scala.collection.Seq<QueryFacade> queryFacades) |
static Object |
customReadValue(HotRodHeader header,
org.jboss.netty.buffer.ChannelBuffer buffer,
AdvancedCache<byte[],byte[]> cache) |
static GetWithMetadataResponse |
getKeyMetadata(HotRodHeader h,
byte[] k,
AdvancedCache<byte[],byte[]> cache) |
static AdvancedCache<byte[],byte[]> |
getOptimizedCache(HotRodHeader h,
AdvancedCache<byte[],byte[]> c) |
static boolean |
readHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
byte version,
long messageId,
HotRodHeader header) |
static scala.Tuple2<byte[],Object> |
readKey(HotRodHeader h,
org.jboss.netty.buffer.ChannelBuffer buffer) |
static scala.Tuple2<RequestParameters,Object> |
readParameters(HotRodHeader header,
org.jboss.netty.buffer.ChannelBuffer buffer) |
static scala.Enumeration.Value |
toResponse(scala.Enumeration.Value request) |
createErrorResponse, createGetResponse, createNotExecutedResponse, createNotExistResponse, createStatsResponse, createSuccessResponse, customReadHeader, customReadKey, customReadValue, getOptimizedCache, readHeader, readKey, readParameters
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
EXPIRATION_DEFAULT, EXPIRATION_NONE
log, logErrorDetectingCrashedMember, logUnableToUpdateView, logViewNullWhileDetectingCrashedMember
debug, debug, debug, debug, debug, debugf, error, info, info, isDebugEnabled, isTraceEnabled, logChannelStillBound, logChannelStillConnected, logErrorBeforeReadingRequest, logExceptionReported, logPostingShutdownRequest, logServerDidNotClose, logServerDidNotUnbind, logSettingMasterThreadsNotSupported, logStartWithArgs, trace, trace, trace, trace, tracef, warn
public static boolean readHeader(org.jboss.netty.buffer.ChannelBuffer buffer, byte version, long messageId, HotRodHeader header)
public static scala.Tuple2<byte[],Object> readKey(HotRodHeader h, org.jboss.netty.buffer.ChannelBuffer buffer)
public static scala.Tuple2<RequestParameters,Object> readParameters(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer)
public static Object createSuccessResponse(HotRodHeader header, byte[] prev)
public static Object createNotExecutedResponse(HotRodHeader header, byte[] prev)
public static Object createNotExistResponse(HotRodHeader header)
public static Object createGetResponse(HotRodHeader h, CacheEntry entry)
public static Object customReadHeader(HotRodHeader h, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache)
public static Object customReadKey(HotRodHeader h, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache, scala.collection.Seq<QueryFacade> queryFacades)
public static GetWithMetadataResponse getKeyMetadata(HotRodHeader h, byte[] k, AdvancedCache<byte[],byte[]> cache)
public static Object customReadValue(HotRodHeader header, org.jboss.netty.buffer.ChannelBuffer buffer, AdvancedCache<byte[],byte[]> cache)
public static Object createStatsResponse(HotRodHeader h, Stats cacheStats, NettyTransport t)
public static ErrorResponse createErrorResponse(HotRodHeader h, Throwable t)
public static AdvancedCache<byte[],byte[]> getOptimizedCache(HotRodHeader h, AdvancedCache<byte[],byte[]> c)
public static scala.Enumeration.Value toResponse(scala.Enumeration.Value request)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.