Class ParserBase

    • Field Detail

      • CLOCK_SKEW_EVENT_UEI

        public static final java.lang.String CLOCK_SKEW_EVENT_UEI
        See Also:
        Constant Field Values
      • ILLEGAL_FLOW_EVENT_UEI

        public static final java.lang.String ILLEGAL_FLOW_EVENT_UEI
        See Also:
        Constant Field Values
    • Method Detail

      • getMessageBuilder

        protected abstract MessageBuilder getMessageBuilder()
      • start

        public void start​(java.util.concurrent.ScheduledExecutorService executorService)
        Specified by:
        start in interface Parser
      • stop

        public void stop()
        Specified by:
        stop in interface Parser
      • getName

        public java.lang.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)
      • setIllegalFlowEventRate

        public void setIllegalFlowEventRate​(long illegalFlowEventRate)
      • getIllegalFlowEventRate

        public long getIllegalFlowEventRate()
      • getSequenceNumberPatience

        public int getSequenceNumberPatience()
      • setSequenceNumberPatience

        public void setSequenceNumberPatience​(int sequenceNumberPatience)
      • getDnsLookupsEnabled

        public boolean getDnsLookupsEnabled()
      • setDnsLookupsEnabled

        public void setDnsLookupsEnabled​(boolean dnsLookupsEnabled)
      • getThreads

        public int getThreads()
      • setThreads

        public void setThreads​(int threads)
      • transmit

        protected java.util.concurrent.CompletableFuture<?> transmit​(RecordProvider packet,
                                                                     Session session,
                                                                     java.net.InetSocketAddress remoteAddress)
      • detectClockSkew

        protected void detectClockSkew​(long packetTimestampMs,
                                       java.net.InetAddress remoteAddress)