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

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

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

        default io.netty.buffer.ByteBuf emptyResponseWithMediaTypes​(HotRodHeader header,
                                                                    HotRodServer server,
                                                                    io.netty.buffer.ByteBufAllocator alloc,
                                                                    OperationStatus status)
      • 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,
                                                    org.infinispan.commons.util.CloseableIterator<byte[]> iterator)
      • iterationStartResponse

        io.netty.buffer.ByteBuf iterationStartResponse​(HotRodHeader header,
                                                       HotRodServer server,
                                                       io.netty.buffer.ByteBufAllocator alloc,
                                                       String iterationId)
      • 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)
      • 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.