Package org.opennms.netmgt.telemetry.protocols.netflow.parser.session

Class TcpSession

java.lang.Object

org.opennms.netmgt.telemetry.protocols.netflow.parser.session.TcpSession

All Implemented Interfaces:

Session

public class TcpSession
extends Object
implements Session

Constructor Summary

Constructors

Constructor	Description
TcpSession(InetAddress remoteAddress, java.util.function.Supplier<SequenceNumberTracker> sequenceNumberTracker)

Method Summary

Modifier and Type	Method	Description
void	addOptions(long observationDomainId, int templateId, Collection<Value<?>> scopes, List<Value<?>> values)
void	addTemplate(long observationDomainId, Template template)
java.util.stream.Stream<ExporterState>	dumpInternalState()
InetAddress	getRemoteAddress()
Session.Resolver	getResolver(long observationDomainId)
void	removeAllTemplate(long observationDomainId, Template.Type type)
void	removeTemplate(long observationDomainId, int templateId)
boolean	verifySequenceNumber(long observationDomainId, long sequenceNumber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TcpSession

public TcpSession(InetAddress remoteAddress,
                  java.util.function.Supplier<SequenceNumberTracker> sequenceNumberTracker)

Method Detail

addTemplate

public void addTemplate(long observationDomainId,
                        Template template)

Specified by:

addTemplate in interface Session

removeTemplate

public void removeTemplate(long observationDomainId,
                           int templateId)

Specified by:

removeTemplate in interface Session

removeAllTemplate

public void removeAllTemplate(long observationDomainId,
                              Template.Type type)

Specified by:

removeAllTemplate in interface Session

addOptions

public void addOptions(long observationDomainId,
                       int templateId,
                       Collection<Value<?>> scopes,
                       List<Value<?>> values)

Specified by:

addOptions in interface Session

getResolver

public Session.Resolver getResolver(long observationDomainId)

Specified by:

getResolver in interface Session

getRemoteAddress

public InetAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface Session

verifySequenceNumber

public boolean verifySequenceNumber(long observationDomainId,
                                    long sequenceNumber)

Specified by:

verifySequenceNumber in interface Session

dumpInternalState

public java.util.stream.Stream<ExporterState> dumpInternalState()