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

Class ParserBase

java.lang.Object

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

All Implemented Interfaces:

Parser

Direct Known Subclasses:

IpfixTcpParser, Netflow5UdpParser, UdpParserBase

public abstract class ParserBase
extends Object
implements Parser

Field Summary

Fields

Modifier and Type	Field and Description
static String	CLOCK_SKEW_EVENT_UEI
static String	ILLEGAL_FLOW_EVENT_UEI

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected abstract byte[]	buildMessage(Iterable<Value<?>> record, RecordEnrichment enrichment)
protected void	detectClockSkew(long packetTimestampMs, InetAddress remoteAddress)
long	getClockSkewEventRate()
boolean	getDnsLookupsEnabled()
long	getIllegalFlowEventRate()
long	getMaxClockSkew()
String	getName()
int	getThreads()
void	setClockSkewEventRate(long clockSkewEventRate)
void	setDnsLookupsEnabled(boolean dnsLookupsEnabled)
void	setIllegalFlowEventRate(long illegalFlowEventRate)
void	setMaxClockSkew(long maxClockSkew)
void	setThreads(int threads)
void	start(ScheduledExecutorService executorService)
void	stop()
protected CompletableFuture<?>	transmit(RecordProvider packet, InetSocketAddress remoteAddress)

Methods inherited from class java.lang.Object

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

Field Detail

CLOCK_SKEW_EVENT_UEI

public static final String CLOCK_SKEW_EVENT_UEI

See Also:

Constant Field Values

ILLEGAL_FLOW_EVENT_UEI

public static final String ILLEGAL_FLOW_EVENT_UEI

See Also:

Constant Field Values

Constructor Detail

ParserBase

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

Method Detail

start

public void start(ScheduledExecutorService executorService)

Specified by:

start in interface Parser

stop

public void stop()

Specified by:

stop in interface Parser

getName

public String getName()

Specified by:

getName in interface Parser

setMaxClockSkew

public void setMaxClockSkew(long maxClockSkew)

getMaxClockSkew

public long getMaxClockSkew()

getClockSkewEventRate

public long getClockSkewEventRate()

setClockSkewEventRate

public void setClockSkewEventRate(long clockSkewEventRate)

setIllegalFlowEventRate

public void setIllegalFlowEventRate(long illegalFlowEventRate)

getIllegalFlowEventRate

public long getIllegalFlowEventRate()

getDnsLookupsEnabled

public boolean getDnsLookupsEnabled()

setDnsLookupsEnabled

public void setDnsLookupsEnabled(boolean dnsLookupsEnabled)

getThreads

public int getThreads()

setThreads

public void setThreads(int threads)

transmit

protected CompletableFuture<?> transmit(RecordProvider packet,
                                        InetSocketAddress remoteAddress)

buildMessage

protected abstract byte[] buildMessage(Iterable<Value<?>> record,
                                       RecordEnrichment enrichment)
                                throws IllegalFlowException

Throws:

IllegalFlowException

detectClockSkew

protected void detectClockSkew(long packetTimestampMs,
                               InetAddress remoteAddress)