Package org.opennms.netmgt.telemetry.listeners.utils

Class BufferUtils

java.lang.Object

org.opennms.netmgt.telemetry.listeners.utils.BufferUtils

public final class BufferUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BufferUtils.Parser<T,E extends Exception>

Method Summary

Modifier and Type	Method	Description
static byte[]	bytes(io.netty.buffer.ByteBuf buffer, int size)
static <R> R	peek(io.netty.buffer.ByteBuf buffer, java.util.function.Function<io.netty.buffer.ByteBuf,R> consumer)
static <T,E extends Exception> List<T>	repeatCount(io.netty.buffer.ByteBuf buffer, int count, BufferUtils.Parser<T,E> parser)
static <T,E extends Exception> List<T>	repeatRemaining(io.netty.buffer.ByteBuf buffer, BufferUtils.Parser<T,E> parser)
static float	sfloat(io.netty.buffer.ByteBuf buffer)
static Long	sint(io.netty.buffer.ByteBuf buffer, int octets)
static Integer	sint16(io.netty.buffer.ByteBuf buffer)
static Integer	sint24(io.netty.buffer.ByteBuf buffer)
static Integer	sint32(io.netty.buffer.ByteBuf buffer)
static Long	sint64(io.netty.buffer.ByteBuf buffer)
static Integer	sint8(io.netty.buffer.ByteBuf buffer)
static void	skip(io.netty.buffer.ByteBuf buffer, int size)
static io.netty.buffer.ByteBuf	slice(io.netty.buffer.ByteBuf buffer, int size)
static com.google.common.primitives.UnsignedLong	uint(io.netty.buffer.ByteBuf buffer, int octets)
static int	uint16(io.netty.buffer.ByteBuf buffer)
static int	uint24(io.netty.buffer.ByteBuf buffer)
static long	uint32(io.netty.buffer.ByteBuf buffer)
static com.google.common.primitives.UnsignedLong	uint64(io.netty.buffer.ByteBuf buffer)
static int	uint8(io.netty.buffer.ByteBuf buffer)

Methods inherited from class java.lang.Object

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

Method Detail

slice

public static io.netty.buffer.ByteBuf slice(io.netty.buffer.ByteBuf buffer,
                                            int size)

peek

public static <R> R peek(io.netty.buffer.ByteBuf buffer,
                         java.util.function.Function<io.netty.buffer.ByteBuf,R> consumer)

sfloat

public static float sfloat(io.netty.buffer.ByteBuf buffer)

uint

public static com.google.common.primitives.UnsignedLong uint(io.netty.buffer.ByteBuf buffer,
                                                             int octets)

sint

public static Long sint(io.netty.buffer.ByteBuf buffer,
                        int octets)

uint8

public static int uint8(io.netty.buffer.ByteBuf buffer)

uint16

public static int uint16(io.netty.buffer.ByteBuf buffer)

uint24

public static int uint24(io.netty.buffer.ByteBuf buffer)

uint32

public static long uint32(io.netty.buffer.ByteBuf buffer)

uint64

public static com.google.common.primitives.UnsignedLong uint64(io.netty.buffer.ByteBuf buffer)

sint8

public static Integer sint8(io.netty.buffer.ByteBuf buffer)

sint16

public static Integer sint16(io.netty.buffer.ByteBuf buffer)

sint24

public static Integer sint24(io.netty.buffer.ByteBuf buffer)

sint32

public static Integer sint32(io.netty.buffer.ByteBuf buffer)

sint64

public static Long sint64(io.netty.buffer.ByteBuf buffer)

bytes

public static byte[] bytes(io.netty.buffer.ByteBuf buffer,
                           int size)

skip

public static void skip(io.netty.buffer.ByteBuf buffer,
                        int size)

repeatRemaining

public static <T,E extends Exception> List<T> repeatRemaining(io.netty.buffer.ByteBuf buffer,
                                                                    BufferUtils.Parser<T,E> parser)
                                                             throws E extends Exception

Throws:

E extends Exception

repeatCount

public static <T,E extends Exception> List<T> repeatCount(io.netty.buffer.ByteBuf buffer,
                                                                int count,
                                                                BufferUtils.Parser<T,E> parser)
                                                         throws E extends Exception

Throws:

E extends Exception