Package 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, UdpParserBase

public abstract class ParserBase
extends Object
implements Parser

Field Summary

Fields

Modifier and Type	Field	Description
static String	CLOCK_SKEW_EVENT_UEI
static String	ILLEGAL_FLOW_EVENT_UEI

Constructor Summary

Constructors

Constructor	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	Description
protected void	detectClockSkew(long packetTimestampMs, InetAddress remoteAddress)
long	getClockSkewEventRate()
String	getDescription()
boolean	getDnsLookupsEnabled()
long	getIllegalFlowEventRate()
long	getMaxClockSkew()
protected abstract MessageBuilder	getMessageBuilder()
String	getName()
int	getSequenceNumberPatience()
int	getThreads()
protected SequenceNumberTracker	sequenceNumberTracker()
void	setClockSkewEventRate(long clockSkewEventRate)
void	setDnsLookupsEnabled(boolean dnsLookupsEnabled)
void	setIllegalFlowEventRate(long illegalFlowEventRate)
void	setMaxClockSkew(long maxClockSkew)
void	setSequenceNumberPatience(int sequenceNumberPatience)
void	setThreads(int threads)
void	start(ScheduledExecutorService executorService)
void	stop()
protected CompletableFuture<?>	transmit(RecordProvider packet, Session session, InetSocketAddress remoteAddress)

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

dumpInternalState

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

getMessageBuilder

protected abstract MessageBuilder getMessageBuilder()

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

getDescription

public String getDescription()

Specified by:

getDescription 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()

getSequenceNumberPatience

public int getSequenceNumberPatience()

setSequenceNumberPatience

public void setSequenceNumberPatience(int sequenceNumberPatience)

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,
                                        Session session,
                                        InetSocketAddress remoteAddress)

detectClockSkew

protected void detectClockSkew(long packetTimestampMs,
                               InetAddress remoteAddress)

sequenceNumberTracker

protected SequenceNumberTracker sequenceNumberTracker()