public class Netflow9UdpParser extends UdpParserBase implements UdpParser, Dispatchable
| Modifier and Type | Class and Description |
|---|---|
static class |
Netflow9UdpParser.SessionKey |
HOUSEKEEPING_INTERVALCLOCK_SKEW_EVENT_UEI, ILLEGAL_FLOW_EVENT_UEI| Constructor and Description |
|---|
Netflow9UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
| Modifier and Type | Method and Description |
|---|---|
protected UdpSessionManager.SessionKey |
buildSessionKey(InetSocketAddress remoteAddress,
InetSocketAddress localAddress) |
boolean |
handles(io.netty.buffer.ByteBuf buffer)
Returns true if the implementor can handle the incoming data, otherwise false.
|
protected RecordProvider |
parse(Session session,
io.netty.buffer.ByteBuf buffer) |
getTemplateTimeout, parse, setTemplateTimeout, start, stopdetectClockSkew, getClockSkewEventRate, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getName, getSequenceNumberPatience, getThreads, sequenceNumberTracker, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, setSequenceNumberPatience, setThreads, transmitpublic Netflow9UdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)
protected RecordProvider parse(Session session, io.netty.buffer.ByteBuf buffer) throws Exception
parse in class UdpParserBaseExceptionpublic boolean handles(io.netty.buffer.ByteBuf buffer)
Dispatchablehandles in interface Dispatchablebuffer - Representing the incoming dataprotected UdpSessionManager.SessionKey buildSessionKey(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
buildSessionKey in class UdpParserBaseCopyright © 2021. All rights reserved.