Package org.infinispan.server.hotrod

Interface VersionedEncoder

All Known Implementing Classes:

AbstractEncoder1x, AbstractTopologyAwareEncoder1x

public interface VersionedEncoder

This class represents the work to be done by an encoder of a particular Hot Rod protocol version.

Since:

5.1

Author:

Galder Zamarreño

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)
io.netty.buffer.ByteBuf	emptyResponse(HotRodHeader header, HotRodServer server, io.netty.buffer.ByteBufAllocator alloc, OperationStatus status)
default io.netty.buffer.ByteBuf	emptyResponseWithMediaTypes(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

Method Detail

authResponse

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

authMechListResponse

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

notExecutedResponse

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

notExistResponse

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

valueResponse

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

successResponse

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

errorResponse

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

bulkGetResponse

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

emptyResponse

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

emptyResponseWithMediaTypes

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

statsResponse

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

valueWithVersionResponse

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

getWithMetadataResponse

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

getStreamResponse

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

getAllResponse

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

bulkGetKeysResponse

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

iterationStartResponse

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

iterationNextResponse

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

counterConfigurationResponse

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

counterNamesResponse

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

multimapCollectionResponse

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

multimapEntryResponse

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

booleanResponse

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

unsignedLongResponse

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

longResponse

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

transactionResponse

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

errorStatus

OperationStatus errorStatus(Throwable t)

writeEvent

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

writeCounterEvent

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

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

recoveryResponse

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