Package org.opennms.netmgt.flows.elastic

Class ElasticFlowRepository

java.lang.Object

org.opennms.netmgt.flows.elastic.ElasticFlowRepository

All Implemented Interfaces:

FlowRepository

public class ElasticFlowRepository
extends java.lang.Object
implements FlowRepository

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	TRACER_FLOW_MODULE

Constructor Summary

Constructors

Constructor	Description
ElasticFlowRepository(com.codahale.metrics.MetricRegistry metricRegistry, io.searchbox.client.JestClient jestClient, IndexStrategy indexStrategy, DocumentEnricher documentEnricher, SessionUtils sessionUtils, NodeDao nodeDao, SnmpInterfaceDao snmpInterfaceDao, Identity identity, TracerRegistry tracerRegistry, EnrichedFlowForwarder enrichedFlowForwarder, IndexSettings indexSettings)

Method Summary

Modifier and Type	Method	Description
int	getBulkRetryCount()
Identity	getIdentity()
TracerRegistry	getTracerRegistry()
boolean	isEnableFlowForwarding()
boolean	isSkipElasticsearchPersistence()
void	persist(java.util.Collection<Flow> flows, FlowSource source)
void	setBulkRetryCount(int bulkRetryCount)
void	setEnableFlowForwarding(boolean enableFlowForwarding)
void	setSkipElasticsearchPersistence(boolean skipElasticsearchPersistence)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

TRACER_FLOW_MODULE

public static final java.lang.String TRACER_FLOW_MODULE

See Also:

Constant Field Values

Constructor Detail

ElasticFlowRepository

public ElasticFlowRepository(com.codahale.metrics.MetricRegistry metricRegistry,
                             io.searchbox.client.JestClient jestClient,
                             IndexStrategy indexStrategy,
                             DocumentEnricher documentEnricher,
                             SessionUtils sessionUtils,
                             NodeDao nodeDao,
                             SnmpInterfaceDao snmpInterfaceDao,
                             Identity identity,
                             TracerRegistry tracerRegistry,
                             EnrichedFlowForwarder enrichedFlowForwarder,
                             IndexSettings indexSettings)

Method Detail

persist

public void persist(java.util.Collection<Flow> flows,
                    FlowSource source)
             throws FlowException

Specified by:

persist in interface FlowRepository

Throws:

FlowException

getIdentity

public Identity getIdentity()

getTracerRegistry

public TracerRegistry getTracerRegistry()

start

public void start()

isEnableFlowForwarding

public boolean isEnableFlowForwarding()

setEnableFlowForwarding

public void setEnableFlowForwarding(boolean enableFlowForwarding)

getBulkRetryCount

public int getBulkRetryCount()

setBulkRetryCount

public void setBulkRetryCount(int bulkRetryCount)

isSkipElasticsearchPersistence

public boolean isSkipElasticsearchPersistence()

setSkipElasticsearchPersistence

public void setSkipElasticsearchPersistence(boolean skipElasticsearchPersistence)