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 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)