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 and Description
static String	OTHER_APPLICATION_NAME
static String	TRACER_FLOW_MODULE
static String	UNKNOWN_APPLICATION_NAME

Constructor Summary

Constructors

Constructor and Description

ElasticFlowRepository(com.codahale.metrics.MetricRegistry metricRegistry, io.searchbox.client.JestClient jestClient, IndexStrategy indexStrategy, DocumentEnricher documentEnricher, ClassificationEngine classificationEngine, org.springframework.transaction.support.TransactionOperations transactionOperations, NodeDao nodeDao, SnmpInterfaceDao snmpInterfaceDao, Identity identity, TracerRegistry tracerRegistry, int bulkRetryCount, long maxFlowDurationMs)

Method Summary

Modifier and Type	Method and Description
void	enrichAndPersistFlows(List<FlowDocument> flowDocuments, FlowSource source)
CompletableFuture<Long>	getFlowCount(List<Filter> filters)
Identity	getIdentity()
CompletableFuture<List<TrafficSummary<String>>>	getTopNApplications(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getTopNApplicationsSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<ConversationKey>>>	getTopNConversations(int N, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<ConversationKey>,Long,Double>>	getTopNConversationsSeries(int N, long step, List<Filter> filters)
TracerRegistry	getTracerRegistry()
void	persist(Collection<Flow> flows, FlowSource source)
void	setIdentity(Identity identity)
void	setTracerRegistry(TracerRegistry tracerRegistry)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

OTHER_APPLICATION_NAME

public static final String OTHER_APPLICATION_NAME

See Also:

Constant Field Values

UNKNOWN_APPLICATION_NAME

public static final String UNKNOWN_APPLICATION_NAME

See Also:

Constant Field Values

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,
                             ClassificationEngine classificationEngine,
                             org.springframework.transaction.support.TransactionOperations transactionOperations,
                             NodeDao nodeDao,
                             SnmpInterfaceDao snmpInterfaceDao,
                             Identity identity,
                             TracerRegistry tracerRegistry,
                             int bulkRetryCount,
                             long maxFlowDurationMs)

Method Detail

persist

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

Specified by:

persist in interface FlowRepository

Throws:

FlowException

enrichAndPersistFlows

public void enrichAndPersistFlows(List<FlowDocument> flowDocuments,
                                  FlowSource source)
                           throws FlowException

Throws:

FlowException

getFlowCount

public CompletableFuture<Long> getFlowCount(List<Filter> filters)

Specified by:

getFlowCount in interface FlowRepository

getTopNApplications

public CompletableFuture<List<TrafficSummary<String>>> getTopNApplications(int N,
                                                                           boolean includeOther,
                                                                           List<Filter> filters)

Specified by:

getTopNApplications in interface FlowRepository

getTopNApplicationsSeries

public CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> getTopNApplicationsSeries(int N,
                                                                                                                     long step,
                                                                                                                     boolean includeOther,
                                                                                                                     List<Filter> filters)

Specified by:

getTopNApplicationsSeries in interface FlowRepository

getTopNConversations

public CompletableFuture<List<TrafficSummary<ConversationKey>>> getTopNConversations(int N,
                                                                                     List<Filter> filters)

Specified by:

getTopNConversations in interface FlowRepository

getTopNConversationsSeries

public CompletableFuture<com.google.common.collect.Table<Directional<ConversationKey>,Long,Double>> getTopNConversationsSeries(int N,
                                                                                                                               long step,
                                                                                                                               List<Filter> filters)

Specified by:

getTopNConversationsSeries in interface FlowRepository

getIdentity

public Identity getIdentity()

setIdentity

public void setIdentity(Identity identity)

getTracerRegistry

public TracerRegistry getTracerRegistry()

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

start

public void start()