Interface VersionedEncoder

All Known Implementing Classes:

Encoder4x

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.channel.Channel channel, Set<String> mechs)
io.netty.buffer.ByteBuf	authResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, byte[] challenge)
io.netty.buffer.ByteBuf	booleanResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, boolean result)
io.netty.buffer.ByteBuf	bulkGetKeysResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CloseableIterator<byte[]> iterator)
io.netty.buffer.ByteBuf	bulkGetResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int size, CacheSet<Map.Entry<byte[],byte[]>> entries)
io.netty.buffer.ByteBuf	counterConfigurationResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, org.infinispan.counter.api.CounterConfiguration configuration)
io.netty.buffer.ByteBuf	counterNamesResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Collection<String> counterNames)
io.netty.buffer.ByteBuf	emptyResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status)
io.netty.buffer.ByteBuf	errorResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, String message, OperationStatus status)
OperationStatus	errorStatus(Throwable t)
io.netty.buffer.ByteBuf	getAllResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Map<byte[],byte[]> map)
io.netty.buffer.ByteBuf	getStreamResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int offset, CacheEntry<byte[],byte[]> entry)
default io.netty.buffer.ByteBuf	getStreamStartResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<?,?> entry, GetStreamResponse getStreamResponse)
io.netty.buffer.ByteBuf	getWithMetadataResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[],byte[]> entry)
io.netty.buffer.ByteBuf	iterationNextResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, IterableIterationResult iterationResult)
io.netty.buffer.ByteBuf	iterationStartResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, String iterationId)
io.netty.buffer.ByteBuf	longResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, long value)
io.netty.buffer.ByteBuf	multimapCollectionResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, Collection<byte[]> values)
io.netty.buffer.ByteBuf	multimapEntryResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[], Collection<byte[]>> ce)
io.netty.buffer.ByteBuf	notExecutedResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[],byte[]> prev)
io.netty.buffer.ByteBuf	notExistResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel)
default io.netty.buffer.ByteBuf	pingResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status)
default io.netty.buffer.ByteBuf	putStreamStartResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int id)
io.netty.buffer.ByteBuf	recoveryResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Collection<XidImpl> xids)
io.netty.buffer.ByteBuf	statsResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Stats stats, NettyTransport transport, ClusterCacheStats clusterCacheStats1)
io.netty.buffer.ByteBuf	successResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, CacheEntry<byte[],byte[]> result)
io.netty.buffer.ByteBuf	transactionResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int xaReturnCode)
io.netty.buffer.ByteBuf	unsignedLongResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, long value)
io.netty.buffer.ByteBuf	valueResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, byte[] prev)
io.netty.buffer.ByteBuf	valueResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, OperationStatus status, CacheEntry<byte[],byte[]> prev)
io.netty.buffer.ByteBuf	valueWithVersionResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, 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 Details

authResponse

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

authMechListResponse

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

notExecutedResponse

io.netty.buffer.ByteBuf notExecutedResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 CacheEntry<byte[],byte[]> prev)

notExistResponse

io.netty.buffer.ByteBuf notExistResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel)

valueResponse

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

valueResponse

io.netty.buffer.ByteBuf valueResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 OperationStatus status,
 CacheEntry<byte[],byte[]> prev)

successResponse

io.netty.buffer.ByteBuf successResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 CacheEntry<byte[],byte[]> result)

errorResponse

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

bulkGetResponse

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

emptyResponse

io.netty.buffer.ByteBuf emptyResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 OperationStatus status)

pingResponse

default io.netty.buffer.ByteBuf pingResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 OperationStatus status)

statsResponse

io.netty.buffer.ByteBuf statsResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 Stats stats,
 NettyTransport transport,
 ClusterCacheStats clusterCacheStats1)

valueWithVersionResponse

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

getWithMetadataResponse

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

getStreamResponse

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

getStreamStartResponse

default io.netty.buffer.ByteBuf getStreamStartResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 CacheEntry<?,?> entry,
 GetStreamResponse getStreamResponse)

putStreamStartResponse

default io.netty.buffer.ByteBuf putStreamStartResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 int id)

getAllResponse

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

bulkGetKeysResponse

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

iterationStartResponse

io.netty.buffer.ByteBuf iterationStartResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 String iterationId)

iterationNextResponse

io.netty.buffer.ByteBuf iterationNextResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 IterableIterationResult iterationResult)

counterConfigurationResponse

io.netty.buffer.ByteBuf counterConfigurationResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 org.infinispan.counter.api.CounterConfiguration configuration)

counterNamesResponse

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

multimapCollectionResponse

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

multimapEntryResponse

io.netty.buffer.ByteBuf multimapEntryResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 OperationStatus status,
 CacheEntry<byte[], Collection<byte[]>> ce)

booleanResponse

io.netty.buffer.ByteBuf booleanResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 boolean result)

unsignedLongResponse

io.netty.buffer.ByteBuf unsignedLongResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 long value)

longResponse

io.netty.buffer.ByteBuf longResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 long value)

transactionResponse

io.netty.buffer.ByteBuf transactionResponse(HotRodHeader header,
 HotRodServer server,
 io.netty.channel.Channel channel,
 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.channel.Channel channel,
 Collection<XidImpl> xids)