Package org.infinispan.server.hotrod

Class AbstractEncoder1x

java.lang.Object

org.infinispan.server.hotrod.AbstractEncoder1x

All Implemented Interfaces:

VersionedEncoder

Direct Known Subclasses:

AbstractTopologyAwareEncoder1x

public abstract class AbstractEncoder1x
extends Object
implements VersionedEncoder

Hot Rod encoder for protocol version 1.1

Since:

5.1

Author:

Galder Zamarreño

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.infinispan.server.hotrod.logging.Log	log
protected boolean	trace

Constructor Summary

Constructors

Constructor	Description
AbstractEncoder1x()

Method Summary

Modifier and Type	Method	Description
io.netty.buffer.ByteBuf	authMechListResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Set<String> mechs)
io.netty.buffer.ByteBuf	authResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] challenge)
io.netty.buffer.ByteBuf	booleanResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, boolean result)
io.netty.buffer.ByteBuf	bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CloseableIterator<byte[]> iterator)
io.netty.buffer.ByteBuf	bulkGetResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int size, CacheSet<Map.Entry<byte[],byte[]>> entries)
io.netty.buffer.ByteBuf	counterConfigurationResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CounterConfiguration configuration)
io.netty.buffer.ByteBuf	counterNamesResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Collection<String> counterNames)
protected org.infinispan.server.hotrod.AbstractHashDistAwareResponse	createHashDistAwareResp(int topologyId, Map<Address,ServerAddress> serverEndpointsMap, Configuration cfg)
io.netty.buffer.ByteBuf	emptyResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status)
io.netty.buffer.ByteBuf	errorResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, String message, OperationStatus status)
OperationStatus	errorStatus(Throwable t)
io.netty.buffer.ByteBuf	getAllResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Map<byte[],byte[]> map)
io.netty.buffer.ByteBuf	getStreamResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int offset, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf	getWithMetadataResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf	iterationNextResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, IterableIterationResult iterationResult)
io.netty.buffer.ByteBuf	iterationStartResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, String iterationId)
io.netty.buffer.ByteBuf	longResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, long value)
io.netty.buffer.ByteBuf	multimapCollectionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, Collection<byte[]> values)
io.netty.buffer.ByteBuf	multimapEntryResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, CacheEntry<WrappedByteArray,Collection<WrappedByteArray>> ce, Collection<byte[]> result)
io.netty.buffer.ByteBuf	notExecutedResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] prev)
io.netty.buffer.ByteBuf	notExistResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc)
io.netty.buffer.ByteBuf	recoveryResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Collection<Xid> xids)
io.netty.buffer.ByteBuf	statsResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, Stats stats, NettyTransport transport, ComponentRegistry cacheRegistry)
io.netty.buffer.ByteBuf	successResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] result)
io.netty.buffer.ByteBuf	transactionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, int xaReturnCode)
io.netty.buffer.ByteBuf	unsignedLongResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, long value)
io.netty.buffer.ByteBuf	valueResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status, byte[] prev)
io.netty.buffer.ByteBuf	valueWithVersionResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, byte[] value, long version)
void	writeCounterEvent(ClientCounterEvent event, io.netty.buffer.ByteBuf buffer)	Writes a ClientCounterEvent, including its header, using a giver channel buffer.
void	writeEvent(org.infinispan.server.hotrod.Events.Event e, io.netty.buffer.ByteBuf buf)	Write an event, including its header, using the given channel buffer

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.hotrod.VersionedEncoder

emptyResponseWithMediaTypes

Field Detail

log

protected static final org.infinispan.server.hotrod.logging.Log log

trace

protected final boolean trace

Constructor Detail

AbstractEncoder1x

public AbstractEncoder1x()

Method Detail

writeEvent

public void writeEvent(org.infinispan.server.hotrod.Events.Event e,
                       io.netty.buffer.ByteBuf buf)

Description copied from interface: VersionedEncoder

Write an event, including its header, using the given channel buffer

Specified by:

writeEvent in interface VersionedEncoder

writeCounterEvent

public void writeCounterEvent(ClientCounterEvent event,
                              io.netty.buffer.ByteBuf buffer)

Description copied from interface: VersionedEncoder

Writes a ClientCounterEvent, including its header, using a giver channel buffer.

Specified by:

writeCounterEvent in interface VersionedEncoder

authResponse

public io.netty.buffer.ByteBuf authResponse(HotRodHeader header,
                                            HotRodServer server,
                                            io.netty.buffer.ByteBufAllocator alloc,
                                            byte[] challenge)

Specified by:

authResponse in interface VersionedEncoder

authMechListResponse

public io.netty.buffer.ByteBuf authMechListResponse(HotRodHeader header,
                                                    HotRodServer server,
                                                    io.netty.buffer.ByteBufAllocator alloc,
                                                    Set<String> mechs)

Specified by:

authMechListResponse in interface VersionedEncoder

notExecutedResponse

public io.netty.buffer.ByteBuf notExecutedResponse(HotRodHeader header,
                                                   HotRodServer server,
                                                   io.netty.buffer.ByteBufAllocator alloc,
                                                   byte[] prev)

Specified by:

notExecutedResponse in interface VersionedEncoder

notExistResponse

public io.netty.buffer.ByteBuf notExistResponse(HotRodHeader header,
                                                HotRodServer server,
                                                io.netty.buffer.ByteBufAllocator alloc)

Specified by:

notExistResponse in interface VersionedEncoder

valueResponse

public io.netty.buffer.ByteBuf valueResponse(HotRodHeader header,
                                             HotRodServer server,
                                             io.netty.buffer.ByteBufAllocator alloc,
                                             OperationStatus status,
                                             byte[] prev)

Specified by:

valueResponse in interface VersionedEncoder

successResponse

public io.netty.buffer.ByteBuf successResponse(HotRodHeader header,
                                               HotRodServer server,
                                               io.netty.buffer.ByteBufAllocator alloc,
                                               byte[] result)

Specified by:

successResponse in interface VersionedEncoder

transactionResponse

public io.netty.buffer.ByteBuf transactionResponse(HotRodHeader header,
                                                   HotRodServer server,
                                                   io.netty.buffer.ByteBufAllocator alloc,
                                                   int xaReturnCode)

Specified by:

transactionResponse in interface VersionedEncoder

recoveryResponse

public io.netty.buffer.ByteBuf recoveryResponse(HotRodHeader header,
                                                HotRodServer server,
                                                io.netty.buffer.ByteBufAllocator alloc,
                                                Collection<Xid> xids)

Specified by:

recoveryResponse in interface VersionedEncoder

errorResponse

public io.netty.buffer.ByteBuf errorResponse(HotRodHeader header,
                                             HotRodServer server,
                                             io.netty.buffer.ByteBufAllocator alloc,
                                             String message,
                                             OperationStatus status)

Specified by:

errorResponse in interface VersionedEncoder

bulkGetResponse

public io.netty.buffer.ByteBuf bulkGetResponse(HotRodHeader header,
                                               HotRodServer server,
                                               io.netty.buffer.ByteBufAllocator alloc,
                                               int size,
                                               CacheSet<Map.Entry<byte[],byte[]>> entries)

Specified by:

bulkGetResponse in interface VersionedEncoder

emptyResponse

public io.netty.buffer.ByteBuf emptyResponse(HotRodHeader header,
                                             HotRodServer server,
                                             io.netty.buffer.ByteBufAllocator alloc,
                                             OperationStatus status)

Specified by:

emptyResponse in interface VersionedEncoder

statsResponse

public io.netty.buffer.ByteBuf statsResponse(HotRodHeader header,
                                             HotRodServer server,
                                             io.netty.buffer.ByteBufAllocator alloc,
                                             Stats stats,
                                             NettyTransport transport,
                                             ComponentRegistry cacheRegistry)

Specified by:

statsResponse in interface VersionedEncoder

getWithMetadataResponse

public io.netty.buffer.ByteBuf getWithMetadataResponse(HotRodHeader header,
                                                       HotRodServer server,
                                                       io.netty.buffer.ByteBufAllocator alloc,
                                                       CacheEntry<byte[],byte[]> entry)

Specified by:

getWithMetadataResponse in interface VersionedEncoder

getStreamResponse

public io.netty.buffer.ByteBuf getStreamResponse(HotRodHeader header,
                                                 HotRodServer server,
                                                 io.netty.buffer.ByteBufAllocator alloc,
                                                 int offset,
                                                 CacheEntry<byte[],byte[]> entry)

Specified by:

getStreamResponse in interface VersionedEncoder

getAllResponse

public io.netty.buffer.ByteBuf getAllResponse(HotRodHeader header,
                                              HotRodServer server,
                                              io.netty.buffer.ByteBufAllocator alloc,
                                              Map<byte[],byte[]> map)

Specified by:

getAllResponse in interface VersionedEncoder

bulkGetKeysResponse

public io.netty.buffer.ByteBuf bulkGetKeysResponse(HotRodHeader header,
                                                   HotRodServer server,
                                                   io.netty.buffer.ByteBufAllocator alloc,
                                                   CloseableIterator<byte[]> iterator)

Specified by:

bulkGetKeysResponse in interface VersionedEncoder

iterationStartResponse

public io.netty.buffer.ByteBuf iterationStartResponse(HotRodHeader header,
                                                      HotRodServer server,
                                                      io.netty.buffer.ByteBufAllocator alloc,
                                                      String iterationId)

Specified by:

iterationStartResponse in interface VersionedEncoder

iterationNextResponse

public io.netty.buffer.ByteBuf iterationNextResponse(HotRodHeader header,
                                                     HotRodServer server,
                                                     io.netty.buffer.ByteBufAllocator alloc,
                                                     IterableIterationResult iterationResult)

Specified by:

iterationNextResponse in interface VersionedEncoder

counterConfigurationResponse

public io.netty.buffer.ByteBuf counterConfigurationResponse(HotRodHeader header,
                                                            HotRodServer server,
                                                            io.netty.buffer.ByteBufAllocator alloc,
                                                            CounterConfiguration configuration)

Specified by:

counterConfigurationResponse in interface VersionedEncoder

counterNamesResponse

public io.netty.buffer.ByteBuf counterNamesResponse(HotRodHeader header,
                                                    HotRodServer server,
                                                    io.netty.buffer.ByteBufAllocator alloc,
                                                    Collection<String> counterNames)

Specified by:

counterNamesResponse in interface VersionedEncoder

multimapCollectionResponse

public io.netty.buffer.ByteBuf multimapCollectionResponse(HotRodHeader header,
                                                          HotRodServer server,
                                                          io.netty.buffer.ByteBufAllocator alloc,
                                                          OperationStatus status,
                                                          Collection<byte[]> values)

Specified by:

multimapCollectionResponse in interface VersionedEncoder

multimapEntryResponse

public io.netty.buffer.ByteBuf multimapEntryResponse(HotRodHeader header,
                                                     HotRodServer server,
                                                     io.netty.buffer.ByteBufAllocator alloc,
                                                     OperationStatus status,
                                                     CacheEntry<WrappedByteArray,Collection<WrappedByteArray>> ce,
                                                     Collection<byte[]> result)

Specified by:

multimapEntryResponse in interface VersionedEncoder

booleanResponse

public io.netty.buffer.ByteBuf booleanResponse(HotRodHeader header,
                                               HotRodServer server,
                                               io.netty.buffer.ByteBufAllocator alloc,
                                               boolean result)

Specified by:

booleanResponse in interface VersionedEncoder

unsignedLongResponse

public io.netty.buffer.ByteBuf unsignedLongResponse(HotRodHeader header,
                                                    HotRodServer server,
                                                    io.netty.buffer.ByteBufAllocator alloc,
                                                    long value)

Specified by:

unsignedLongResponse in interface VersionedEncoder

valueWithVersionResponse

public io.netty.buffer.ByteBuf valueWithVersionResponse(HotRodHeader header,
                                                        HotRodServer server,
                                                        io.netty.buffer.ByteBufAllocator alloc,
                                                        byte[] value,
                                                        long version)

Specified by:

valueWithVersionResponse in interface VersionedEncoder

longResponse

public io.netty.buffer.ByteBuf longResponse(HotRodHeader header,
                                            HotRodServer server,
                                            io.netty.buffer.ByteBufAllocator alloc,
                                            long value)

Specified by:

longResponse in interface VersionedEncoder

errorStatus

public OperationStatus errorStatus(Throwable t)

Specified by:

errorStatus in interface VersionedEncoder

createHashDistAwareResp

protected org.infinispan.server.hotrod.AbstractHashDistAwareResponse createHashDistAwareResp(int topologyId,
                                                                                             Map<Address,ServerAddress> serverEndpointsMap,
                                                                                             Configuration cfg)