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,
                                                     java.util.Set<java.lang.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<java.util.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,
                                               java.util.Map<byte[],​byte[]> map)
      • iterationStartResponse

        io.netty.buffer.ByteBuf iterationStartResponse​(HotRodHeader header,
                                                       HotRodServer server,
                                                       io.netty.buffer.ByteBufAllocator alloc,
                                                       java.lang.String iterationId)
      • counterNamesResponse

        io.netty.buffer.ByteBuf counterNamesResponse​(HotRodHeader header,
                                                     HotRodServer server,
                                                     io.netty.buffer.ByteBufAllocator alloc,
                                                     java.util.Collection<java.lang.String> counterNames)
      • multimapCollectionResponse

        io.netty.buffer.ByteBuf multimapCollectionResponse​(HotRodHeader header,
                                                           HotRodServer server,
                                                           io.netty.buffer.ByteBufAllocator alloc,
                                                           OperationStatus status,
                                                           java.util.Collection<byte[]> values)
      • 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.
      • recoveryResponse

        io.netty.buffer.ByteBuf recoveryResponse​(HotRodHeader header,
                                                 HotRodServer server,
                                                 io.netty.buffer.ByteBufAllocator alloc,
                                                 java.util.Collection<javax.transaction.xa.Xid> xids)