org.thales.punch.libraries.commons.netty.codec

Class NettyNetflowDecoder

java.lang.Object

org.thales.punch.libraries.commons.netty.codec.NettyNetflowDecoder

All Implemented Interfaces:

NettyCodec

public class NettyNetflowDecoder
extends Object
implements NettyCodec

This decoder transforms a Netflow packet into a sequence of netflow Json string. Ready to be sent into a Storm topology. It supports Netflow v5 and v9 format.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
NettyNetflowDecoder(int capacity, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Watch out : the capacity parameter is a fixed capacity.

Method Summary

Modifier and Type	Method and Description
List<String>	decode(byte[] in) Decode a received payload and return the lumberjack frames contained in it.
List<String>	decode(io.netty.buffer.ByteBuf in) Decode a received payload and return the lumberjack frames contained in it.
static String	toIpv4(int v)
static int	toIpv4(String v)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyNetflowDecoder

public NettyNetflowDecoder(int capacity,
                           org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Watch out : the capacity parameter is a fixed capacity. You must set enough capacity to decode compressed frame.

Parameters:

capacity - the working compression/decompression buffer capacity

metricsContext - the metric context

Method Detail

decode

public List<String> decode(io.netty.buffer.ByteBuf in)

Decode a received payload and return the lumberjack frames contained in it. If the payload is not complete, an empty list is returned. The next calls will succeeds (eventually).

Specified by:

decode in interface NettyCodec

Parameters:

in - the input payload ByteBuf

Returns:

the decoded frames

decode

public List<String> decode(byte[] in)

Decode a received payload and return the lumberjack frames contained in it. If the payload is not complete, an empty list is returned. The next calls will succeeds (eventually).

Parameters:

in - the input payload byte array

Returns:

the decoded frames

Throws:

IllegalArgumentException - if the data cannot be lumberjack decoded

toIpv4

public static String toIpv4(int v)

Parameters:

v - the int representation

Returns:

the String representation of of that IPV4 address

toIpv4

public static int toIpv4(String v)

Parameters:

v - the String representation of an IPV4 address

Returns:

the int representation of that IPV4 address