Package io.kroxylicious.proxy.frame

Interface ByteBufAccessor

All Superinterfaces:
org.apache.kafka.common.protocol.Readable, org.apache.kafka.common.protocol.Writable
All Known Implementing Classes:
ByteBufAccessorImpl
public interface ByteBufAccessor extends org.apache.kafka.common.protocol.Readable, org.apache.kafka.common.protocol.Writable
Provides read and write access to byte buffer for serializing frames.

  • Method Details

    • readByte

      byte readByte()
      Specified by:
      readByte in interface org.apache.kafka.common.protocol.Readable

    • readShort

      short readShort()
      Specified by:
      readShort in interface org.apache.kafka.common.protocol.Readable

    • readInt

      int readInt()
      Specified by:
      readInt in interface org.apache.kafka.common.protocol.Readable

    • readLong

      long readLong()
      Specified by:
      readLong in interface org.apache.kafka.common.protocol.Readable

    • readDouble

      double readDouble()
      Specified by:
      readDouble in interface org.apache.kafka.common.protocol.Readable

    • readArray

      byte[] readArray(int length)
      Specified by:
      readArray in interface org.apache.kafka.common.protocol.Readable

    • readUnsignedVarint

      int readUnsignedVarint()
      Specified by:
      readUnsignedVarint in interface org.apache.kafka.common.protocol.Readable

    • readByteBuffer

      ByteBuffer readByteBuffer(int length)
      Specified by:
      readByteBuffer in interface org.apache.kafka.common.protocol.Readable

    • readVarint

      int readVarint()
      Specified by:
      readVarint in interface org.apache.kafka.common.protocol.Readable

    • readVarlong

      long readVarlong()
      Specified by:
      readVarlong in interface org.apache.kafka.common.protocol.Readable

    • remaining

      int remaining()
      Specified by:
      remaining in interface org.apache.kafka.common.protocol.Readable

    • readerIndex

      int readerIndex()

    • readerIndex

      void readerIndex(int readerIndex)

    • writeByte

      void writeByte(byte val)
      Specified by:
      writeByte in interface org.apache.kafka.common.protocol.Writable

    • writeShort

      void writeShort(short val)
      Specified by:
      writeShort in interface org.apache.kafka.common.protocol.Writable

    • writeInt

      void writeInt(int val)
      Specified by:
      writeInt in interface org.apache.kafka.common.protocol.Writable

    • writeLong

      void writeLong(long val)
      Specified by:
      writeLong in interface org.apache.kafka.common.protocol.Writable

    • writeDouble

      void writeDouble(double val)
      Specified by:
      writeDouble in interface org.apache.kafka.common.protocol.Writable

    • writeByteArray

      void writeByteArray(byte[] arr)
      Specified by:
      writeByteArray in interface org.apache.kafka.common.protocol.Writable

    • writeUnsignedVarint

      void writeUnsignedVarint(int i)
      Specified by:
      writeUnsignedVarint in interface org.apache.kafka.common.protocol.Writable

    • writeByteBuffer

      void writeByteBuffer(ByteBuffer byteBuffer)
      Specified by:
      writeByteBuffer in interface org.apache.kafka.common.protocol.Writable

    • writeVarint

      void writeVarint(int i)
      Specified by:
      writeVarint in interface org.apache.kafka.common.protocol.Writable

    • writeVarlong

      void writeVarlong(long i)
      Specified by:
      writeVarlong in interface org.apache.kafka.common.protocol.Writable

    • ensureWritable

      void ensureWritable(int encodedSize)

    • writerIndex

      int writerIndex()

    • writeBytes

      void writeBytes(io.netty.buffer.ByteBuf buf, int length)