Package com.impossibl.postgres.utils

Class ByteBufs

java.lang.Object

com.impossibl.postgres.utils.ByteBufs

public class ByteBufs
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ByteBufs.DecodeFunction
static interface	ByteBufs.EncodeFunction

Constructor Summary

Constructors

Constructor	Description
ByteBufs()

Method Summary

Modifier and Type	Method	Description
static io.netty.buffer.ByteBuf[]	allocAll(io.netty.buffer.ByteBufAllocator alloc, int count)
static io.netty.buffer.ByteBuf[]	duplicateAll(io.netty.buffer.ByteBuf[] buffers)
static io.netty.buffer.ByteBuf[]	encode(io.netty.buffer.ByteBufAllocator alloc, CharSequence[] textBuffers)
static Object	lengthDecode(io.netty.buffer.ByteBuf buffer, ByteBufs.DecodeFunction decode)
static Object	lengthDecodeBinary(Type.Codec.Decoder<io.netty.buffer.ByteBuf> decoder, Context context, Type type, Short typeLength, Integer typeModifier, io.netty.buffer.ByteBuf buffer, Class<?> targetClass, Object targetContext)
static int	lengthEncode(io.netty.buffer.ByteBuf buffer, Object value, ByteBufs.EncodeFunction encode)
static void	lengthEncodeBinary(Type.Codec.Encoder<io.netty.buffer.ByteBuf> encoder, Context context, Type type, Object value, Object sourceContext, io.netty.buffer.ByteBuf buffer)
static String	readCString(io.netty.buffer.ByteBuf buffer, Charset charset)
static void	releaseAll(io.netty.buffer.ByteBuf[] byteBufs)
static io.netty.buffer.ByteBuf[]	retainedDuplicateAll(io.netty.buffer.ByteBuf[] buffers)
static void	writeCString(io.netty.buffer.ByteBuf buffer, byte[] valBytes)
static void	writeCString(io.netty.buffer.ByteBuf buffer, String val, Charset charset)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ByteBufs

public ByteBufs()

Method Detail

allocAll

public static io.netty.buffer.ByteBuf[] allocAll(io.netty.buffer.ByteBufAllocator alloc,
                                                 int count)

duplicateAll

public static io.netty.buffer.ByteBuf[] duplicateAll(io.netty.buffer.ByteBuf[] buffers)

retainedDuplicateAll

public static io.netty.buffer.ByteBuf[] retainedDuplicateAll(io.netty.buffer.ByteBuf[] buffers)

releaseAll

public static void releaseAll(io.netty.buffer.ByteBuf[] byteBufs)

encode

public static io.netty.buffer.ByteBuf[] encode(io.netty.buffer.ByteBufAllocator alloc,
                                               CharSequence[] textBuffers)

lengthEncodeBinary

public static void lengthEncodeBinary(Type.Codec.Encoder<io.netty.buffer.ByteBuf> encoder,
                                      Context context,
                                      Type type,
                                      Object value,
                                      Object sourceContext,
                                      io.netty.buffer.ByteBuf buffer)
                               throws IOException

Throws:

IOException

lengthEncode

public static int lengthEncode(io.netty.buffer.ByteBuf buffer,
                               Object value,
                               ByteBufs.EncodeFunction encode)
                        throws IOException

Throws:

IOException

lengthDecodeBinary

public static Object lengthDecodeBinary(Type.Codec.Decoder<io.netty.buffer.ByteBuf> decoder,
                                        Context context,
                                        Type type,
                                        Short typeLength,
                                        Integer typeModifier,
                                        io.netty.buffer.ByteBuf buffer,
                                        Class<?> targetClass,
                                        Object targetContext)
                                 throws IOException

Throws:

IOException

lengthDecode

public static Object lengthDecode(io.netty.buffer.ByteBuf buffer,
                                  ByteBufs.DecodeFunction decode)
                           throws IOException

Throws:

IOException

readCString

public static String readCString(io.netty.buffer.ByteBuf buffer,
                                 Charset charset)

writeCString

public static void writeCString(io.netty.buffer.ByteBuf buffer,
                                String val,
                                Charset charset)

writeCString

public static void writeCString(io.netty.buffer.ByteBuf buffer,
                                byte[] valBytes)