Package org.opennms.netmgt.telemetry.protocols.netflow.parser

Class UdpParserBase

java.lang.Object

org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase

org.opennms.netmgt.telemetry.protocols.netflow.parser.UdpParserBase

All Implemented Interfaces:

Parser, UdpParser

Direct Known Subclasses:

IpfixUdpParser, Netflow5UdpParser, Netflow9UdpParser

public abstract class UdpParserBase
extends ParserBase
implements UdpParser

Field Summary

Fields

Modifier and Type	Field	Description
static long	HOUSEKEEPING_INTERVAL

Fields inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase

CLOCK_SKEW_EVENT_UEI, ILLEGAL_FLOW_EVENT_UEI

Constructor Summary

Constructors

Constructor	Description
UdpParserBase(Protocol protocol, java.lang.String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
protected abstract UdpSessionManager.SessionKey	buildSessionKey(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
java.time.Duration	getTemplateTimeout()
java.util.concurrent.CompletableFuture<?>	parse(io.netty.buffer.ByteBuf buffer, java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
protected abstract RecordProvider	parse(Session session, io.netty.buffer.ByteBuf buffer)
void	setTemplateTimeout(java.time.Duration templateTimeout)
void	start(java.util.concurrent.ScheduledExecutorService executorService)
void	stop()

Methods inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase

detectClockSkew, getClockSkewEventRate, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getMessageBuilder, getName, getSequenceNumberPatience, getThreads, sequenceNumberTracker, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, setSequenceNumberPatience, setThreads, transmit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.netmgt.telemetry.api.receiver.Parser

getName

Field Detail

HOUSEKEEPING_INTERVAL

public static final long HOUSEKEEPING_INTERVAL

See Also:

Constant Field Values

Constructor Detail

UdpParserBase

public UdpParserBase(Protocol protocol,
                     java.lang.String name,
                     AsyncDispatcher<TelemetryMessage> dispatcher,
                     EventForwarder eventForwarder,
                     Identity identity,
                     DnsResolver dnsResolver,
                     com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

parse

protected abstract RecordProvider parse(Session session,
                                        io.netty.buffer.ByteBuf buffer)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

buildSessionKey

protected abstract UdpSessionManager.SessionKey buildSessionKey(java.net.InetSocketAddress remoteAddress,
                                                                java.net.InetSocketAddress localAddress)

parse

public final java.util.concurrent.CompletableFuture<?> parse(io.netty.buffer.ByteBuf buffer,
                                                             java.net.InetSocketAddress remoteAddress,
                                                             java.net.InetSocketAddress localAddress)
                                                      throws java.lang.Exception

Specified by:

parse in interface UdpParser

Throws:

java.lang.Exception

start

public void start(java.util.concurrent.ScheduledExecutorService executorService)

Specified by:

start in interface Parser

Overrides:

start in class ParserBase

stop

public void stop()

Specified by:

stop in interface Parser

Overrides:

stop in class ParserBase

getTemplateTimeout

public java.time.Duration getTemplateTimeout()

setTemplateTimeout

public void setTemplateTimeout(java.time.Duration templateTimeout)