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	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, int bulkRetryCount, long maxFlowDurationMs)

Method Summary

Modifier and Type	Method and Description
void	enrichAndPersistFlows(List<FlowDocument> flowDocuments, FlowSource source)
CompletableFuture<Set<Integer>>	getExportersWithFlows(int limit, List<Filter> filters)
CompletableFuture<Long>	getFlowCount(List<Filter> filters)
CompletableFuture<Set<Integer>>	getSnmpInterfaceIdsWithFlows(int limit, List<Filter> filters)
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<Conversation>>>	getTopNConversations(int N, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getTopNConversationsSeries(int N, long step, List<Filter> filters)
void	persist(Collection<Flow> flows, FlowSource source)

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

Constructor Detail

ElasticFlowRepository

public ElasticFlowRepository(com.codahale.metrics.MetricRegistry metricRegistry,
                             io.searchbox.client.JestClient jestClient,
                             IndexStrategy indexStrategy,
                             DocumentEnricher documentEnricher,
                             ClassificationEngine classificationEngine,
                             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

getExportersWithFlows

public CompletableFuture<Set<Integer>> getExportersWithFlows(int limit,
                                                             List<Filter> filters)

Specified by:

getExportersWithFlows in interface FlowRepository

getSnmpInterfaceIdsWithFlows

public CompletableFuture<Set<Integer>> getSnmpInterfaceIdsWithFlows(int limit,
                                                                    List<Filter> filters)

Specified by:

getSnmpInterfaceIdsWithFlows 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<Conversation>>> getTopNConversations(int N,
                                                                                  List<Filter> filters)

Specified by:

getTopNConversations in interface FlowRepository

getTopNConversationsSeries

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

Specified by:

getTopNConversationsSeries in interface FlowRepository