Class UdpParserBase
- java.lang.Object
-
- org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase
-
- org.opennms.netmgt.telemetry.protocols.netflow.parser.UdpParserBase
-
- 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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract UdpSessionManager.SessionKey
buildSessionKey(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
java.lang.Object
dumpInternalState()
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, getDescription, 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
getDescription, 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
-
start
public void start(java.util.concurrent.ScheduledExecutorService executorService)
- Specified by:
start
in interfaceParser
- Overrides:
start
in classParserBase
-
stop
public void stop()
- Specified by:
stop
in interfaceParser
- Overrides:
stop
in classParserBase
-
getTemplateTimeout
public java.time.Duration getTemplateTimeout()
-
setTemplateTimeout
public void setTemplateTimeout(java.time.Duration templateTimeout)
-
dumpInternalState
public java.lang.Object dumpInternalState()
- Specified by:
dumpInternalState
in interfaceParser
-
-