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 Link icon

    • authResponse Link icon

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

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

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

      io.netty.buffer.ByteBuf notExistResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel)
    • valueResponse Link icon

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

      io.netty.buffer.ByteBuf transactionResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, int xaReturnCode)
    • errorStatus Link icon

      OperationStatus errorStatus(Throwable t)
    • writeEvent Link icon

      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 Link icon

      void writeCounterEvent(ClientCounterEvent event, io.netty.buffer.ByteBuf buffer)
      Writes a ClientCounterEvent, including its header, using a giver channel buffer.
    • recoveryResponse Link icon

      io.netty.buffer.ByteBuf recoveryResponse(HotRodHeader header, HotRodServer server, io.netty.channel.Channel channel, Collection<XidImpl> xids)