Package org.opennms.netmgt.flows.elastic.thresholding

Class FlowThresholding

java.lang.Object

org.opennms.netmgt.flows.elastic.thresholding.FlowThresholding

All Implemented Interfaces:

Closeable, AutoCloseable

public class FlowThresholding
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field	Description
static String	RESOURCE_GROUP
static String	RESOURCE_TYPE_NAME
static String	SERVICE_NAME
long	systemIdHash

Constructor Summary

Constructors

Constructor	Description
FlowThresholding(ThresholdingService thresholdingService, CollectionAgentFactory collectionAgentFactory, PersisterFactory persisterFactory, IpInterfaceDao ipInterfaceDao, DistPollerDao distPollerDao, SnmpInterfaceDao snmpInterfaceDao, FilterDao filterDao)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getIdleTimeoutMs()
Set<ExporterKey>	getSessions()
long	getStepSizeMs()
void	setIdleTimeoutMs(long idleTimeoutMs)
void	setStepSizeMs(long stepSizeMs)
void	threshold(List<FlowDocument> documents, ProcessingOptions options)

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

RESOURCE_TYPE_NAME

public static final String RESOURCE_TYPE_NAME

See Also:

Constant Field Values

RESOURCE_GROUP

public static final String RESOURCE_GROUP

See Also:

Constant Field Values

systemIdHash

public final long systemIdHash

Constructor Detail

FlowThresholding

public FlowThresholding(ThresholdingService thresholdingService,
                        CollectionAgentFactory collectionAgentFactory,
                        PersisterFactory persisterFactory,
                        IpInterfaceDao ipInterfaceDao,
                        DistPollerDao distPollerDao,
                        SnmpInterfaceDao snmpInterfaceDao,
                        FilterDao filterDao)

Method Detail

getStepSizeMs

public long getStepSizeMs()

setStepSizeMs

public void setStepSizeMs(long stepSizeMs)

getIdleTimeoutMs

public long getIdleTimeoutMs()

setIdleTimeoutMs

public void setIdleTimeoutMs(long idleTimeoutMs)

threshold

public void threshold(List<FlowDocument> documents,
                      ProcessingOptions options)
               throws ExecutionException,
                      ThresholdInitializationException

Throws:

ExecutionException

ThresholdInitializationException

getSessions

public Set<ExporterKey> getSessions()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable