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 Object
implements FlowRepository

Field Summary

Fields

Modifier and Type	Field	Description
static 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)
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, int bulkSize, int bulkFlushMs)

Method Summary

Modifier and Type	Method	Description
int	getBulkFlushMs()
int	getBulkRetryCount()
int	getBulkSize()
Identity	getIdentity()
TracerRegistry	getTracerRegistry()
boolean	isEnableFlowForwarding()
boolean	isSkipElasticsearchPersistence()
void	persist(Collection<Flow> flows, FlowSource source)
void	setBulkFlushMs(int bulkFlushMs)
void	setBulkRetryCount(int bulkRetryCount)
void	setBulkSize(int bulkSize)
void	setEnableFlowForwarding(boolean enableFlowForwarding)
void	setSkipElasticsearchPersistence(boolean skipElasticsearchPersistence)
void	start()
void	stop()

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 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)

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,
                             int bulkSize,
                             int bulkFlushMs)

Method Detail

persist

public void persist(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()

stop

public void stop()
          throws FlowException

Throws:

FlowException

isEnableFlowForwarding

public boolean isEnableFlowForwarding()

setEnableFlowForwarding

public void setEnableFlowForwarding(boolean enableFlowForwarding)

getBulkSize

public int getBulkSize()

setBulkSize

public void setBulkSize(int bulkSize)

getBulkRetryCount

public int getBulkRetryCount()

setBulkRetryCount

public void setBulkRetryCount(int bulkRetryCount)

getBulkFlushMs

public int getBulkFlushMs()

setBulkFlushMs

public void setBulkFlushMs(int bulkFlushMs)

isSkipElasticsearchPersistence

public boolean isSkipElasticsearchPersistence()

setSkipElasticsearchPersistence

public void setSkipElasticsearchPersistence(boolean skipElasticsearchPersistence)