public class Netflow5UdpParser extends UdpParserBase implements UdpParser, Dispatchable
HOUSEKEEPING_INTERVALCLOCK_SKEW_EVENT_UEI, ILLEGAL_FLOW_EVENT_UEI| Constructor and Description |
|---|
Netflow5UdpParser(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 Netflow5UdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)
public boolean handles(io.netty.buffer.ByteBuf buffer)
Dispatchablehandles in interface Dispatchablebuffer - Representing the incoming dataprotected RecordProvider parse(Session session, io.netty.buffer.ByteBuf buffer) throws Exception
parse in class UdpParserBaseExceptionprotected UdpSessionManager.SessionKey buildSessionKey(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
buildSessionKey in class UdpParserBaseCopyright © 2021. All rights reserved.