org.infinispan.server.hotrod

Class Decoder10

java.lang.Object

org.infinispan.server.hotrod.AbstractVersionedDecoder

org.infinispan.server.hotrod.Decoder10

All Implemented Interfaces:

Log, ServerConstants

public class Decoder10
extends AbstractVersionedDecoder
implements ServerConstants, Log

HotRod protocol decoder specific for specification version 1.0.

Since:

4.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
Decoder10()

Method Summary

Methods

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)

Methods inherited from class org.infinispan.server.hotrod.AbstractVersionedDecoder

createErrorResponse, createGetResponse, createNotExecutedResponse, createNotExistResponse, createStatsResponse, createSuccessResponse, customReadHeader, customReadKey, customReadValue, getOptimizedCache, readHeader, readKey, readParameters

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.server.core.ServerConstants

EXPIRATION_DEFAULT, EXPIRATION_NONE

Methods inherited from interface org.infinispan.server.hotrod.logging.Log

log, logErrorDetectingCrashedMember, logUnableToUpdateView, logViewNullWhileDetectingCrashedMember

Methods inherited from interface org.infinispan.server.core.logging.Log

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

Constructor Detail

Decoder10

public Decoder10()

Method Detail

readHeader

public static boolean readHeader(org.jboss.netty.buffer.ChannelBuffer buffer,
                 byte version,
                 long messageId,
                 HotRodHeader header)

readKey

public static scala.Tuple2<byte[],Object> readKey(HotRodHeader h,
                                  org.jboss.netty.buffer.ChannelBuffer buffer)

readParameters

public static scala.Tuple2<RequestParameters,Object> readParameters(HotRodHeader header,
                                                    org.jboss.netty.buffer.ChannelBuffer buffer)

createSuccessResponse

public static Object createSuccessResponse(HotRodHeader header,
                           byte[] prev)

createNotExecutedResponse

public static Object createNotExecutedResponse(HotRodHeader header,
                               byte[] prev)

createNotExistResponse

public static Object createNotExistResponse(HotRodHeader header)

createGetResponse

public static Object createGetResponse(HotRodHeader h,
                       CacheEntry entry)

customReadHeader

public static Object customReadHeader(HotRodHeader h,
                      org.jboss.netty.buffer.ChannelBuffer buffer,
                      AdvancedCache<byte[],byte[]> cache)

customReadKey

public static Object customReadKey(HotRodHeader h,
                   org.jboss.netty.buffer.ChannelBuffer buffer,
                   AdvancedCache<byte[],byte[]> cache,
                   scala.collection.Seq<QueryFacade> queryFacades)

getKeyMetadata

public static GetWithMetadataResponse getKeyMetadata(HotRodHeader h,
                                     byte[] k,
                                     AdvancedCache<byte[],byte[]> cache)

customReadValue

public static Object customReadValue(HotRodHeader header,
                     org.jboss.netty.buffer.ChannelBuffer buffer,
                     AdvancedCache<byte[],byte[]> cache)

createStatsResponse

public static Object createStatsResponse(HotRodHeader h,
                         Stats cacheStats,
                         NettyTransport t)

createErrorResponse

public static ErrorResponse createErrorResponse(HotRodHeader h,
                                Throwable t)

getOptimizedCache

public static AdvancedCache<byte[],byte[]> getOptimizedCache(HotRodHeader h,
                                             AdvancedCache<byte[],byte[]> c)

toResponse

public static scala.Enumeration.Value toResponse(scala.Enumeration.Value request)