public class Netflow5UdpParser extends ParserBase implements UdpParser, Dispatchable
CLOCK_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 byte[] |
buildMessage(Iterable<Value<?>> record,
RecordEnrichment enrichment) |
boolean |
handles(io.netty.buffer.ByteBuf buffer)
Returns true if the implementor can handle the incoming data, otherwise false.
|
CompletableFuture<?> |
parse(io.netty.buffer.ByteBuf buffer,
InetSocketAddress remoteAddress,
InetSocketAddress localAddress) |
detectClockSkew, getClockSkewEventRate, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getName, getThreads, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, setThreads, start, stop, 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 datapublic CompletableFuture<?> parse(io.netty.buffer.ByteBuf buffer, InetSocketAddress remoteAddress, InetSocketAddress localAddress) throws Exception
protected byte[] buildMessage(Iterable<Value<?>> record, RecordEnrichment enrichment) throws IllegalFlowException
buildMessage in class ParserBaseIllegalFlowExceptionCopyright © 2021. All rights reserved.