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 class ParserBase
extends Object
implements Parser

Field Summary

Fields

Modifier and Type	Field and Description
static String	CLOCK_SKEW_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 void	detectClockSkew(long packetTimestampMs, InetAddress remoteAddress)
long	getClockSkewEventRate()
boolean	getDnsLookupsEnabled()
long	getMaxClockSkew()
String	getName()
int	getThreads()
static ByteBuffer	serialize(Protocol protocol, Iterable<Value<?>> record)
void	setClockSkewEventRate(long clockSkewEventRate)
void	setDnsLookupsEnabled(boolean dnsLookupsEnabled)
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

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)

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)

serialize

public static ByteBuffer serialize(Protocol protocol,
                                   Iterable<Value<?>> record)

detectClockSkew

protected void detectClockSkew(long packetTimestampMs,
                               InetAddress remoteAddress)