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_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, SessionUtils sessionUtils, NodeDao nodeDao, SnmpInterfaceDao snmpInterfaceDao, Identity identity, TracerRegistry tracerRegistry, EnrichedFlowForwarder enrichedFlowForwarder, IndexSettings indexSettings, int bulkRetryCount, long maxFlowDurationMs)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<List<String>>	getApplications(String matchingPrefix, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getApplicationSeries(Set<String> applications, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getApplicationSummaries(Set<String> applications, boolean includeOther, List<Filter> filters)
CompletableFuture<List<String>>	getConversations(String locationPattern, String protocolPattern, String lowerIPPattern, String upperIPPattern, String applicationPattern, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getConversationSeries(Set<String> conversations, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Conversation>>>	getConversationSummaries(Set<String> conversations, boolean includeOther, List<Filter> filters)
CompletableFuture<Long>	getFlowCount(List<Filter> filters)
CompletableFuture<List<String>>	getHosts(String regex, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>>	getHostSeries(Set<String> hosts, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Host>>>	getHostSummaries(Set<String> hosts, boolean includeOther, List<Filter> filters)
Identity	getIdentity()
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getTopNApplicationSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getTopNApplicationSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getTopNConversationSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Conversation>>>	getTopNConversationSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>>	getTopNHostSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Host>>>	getTopNHostSummaries(int N, boolean includeOther, List<Filter> filters)
TracerRegistry	getTracerRegistry()
void	persist(Collection<Flow> flows, FlowSource source)
CompletableFuture<Conversation>	resolveHostnameForConversation(String convoKey, List<Filter> filters)
CompletableFuture<Host>	resolveHostnameForHost(String host, List<Filter> filters)
void	setEnableFlowForwarding(boolean enableFlowForwarding)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

OTHER_NAME

public static final String OTHER_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,
                             SessionUtils sessionUtils,
                             NodeDao nodeDao,
                             SnmpInterfaceDao snmpInterfaceDao,
                             Identity identity,
                             TracerRegistry tracerRegistry,
                             EnrichedFlowForwarder enrichedFlowForwarder,
                             IndexSettings indexSettings,
                             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

getFlowCount

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

Specified by:

getFlowCount in interface FlowRepository

getApplications

public CompletableFuture<List<String>> getApplications(String matchingPrefix,
                                                       long limit,
                                                       List<Filter> filters)

Specified by:

getApplications in interface FlowRepository

getTopNApplicationSummaries

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

Specified by:

getTopNApplicationSummaries in interface FlowRepository

getApplicationSummaries

public CompletableFuture<List<TrafficSummary<String>>> getApplicationSummaries(Set<String> applications,
                                                                               boolean includeOther,
                                                                               List<Filter> filters)

Specified by:

getApplicationSummaries in interface FlowRepository

getApplicationSeries

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

Specified by:

getApplicationSeries in interface FlowRepository

getTopNApplicationSeries

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

Specified by:

getTopNApplicationSeries in interface FlowRepository

getConversations

public CompletableFuture<List<String>> getConversations(String locationPattern,
                                                        String protocolPattern,
                                                        String lowerIPPattern,
                                                        String upperIPPattern,
                                                        String applicationPattern,
                                                        long limit,
                                                        List<Filter> filters)

Specified by:

getConversations in interface FlowRepository

getTopNConversationSummaries

public CompletableFuture<List<TrafficSummary<Conversation>>> getTopNConversationSummaries(int N,
                                                                                          boolean includeOther,
                                                                                          List<Filter> filters)

Specified by:

getTopNConversationSummaries in interface FlowRepository

getConversationSummaries

public CompletableFuture<List<TrafficSummary<Conversation>>> getConversationSummaries(Set<String> conversations,
                                                                                      boolean includeOther,
                                                                                      List<Filter> filters)

Specified by:

getConversationSummaries in interface FlowRepository

getConversationSeries

public CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> getConversationSeries(Set<String> conversations,
                                                                                                                       long step,
                                                                                                                       boolean includeOther,
                                                                                                                       List<Filter> filters)

Specified by:

getConversationSeries in interface FlowRepository

getTopNConversationSeries

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

Specified by:

getTopNConversationSeries in interface FlowRepository

resolveHostnameForConversation

public CompletableFuture<Conversation> resolveHostnameForConversation(String convoKey,
                                                                      List<Filter> filters)

getHosts

public CompletableFuture<List<String>> getHosts(String regex,
                                                long limit,
                                                List<Filter> filters)

Specified by:

getHosts in interface FlowRepository

getTopNHostSummaries

public CompletableFuture<List<TrafficSummary<Host>>> getTopNHostSummaries(int N,
                                                                          boolean includeOther,
                                                                          List<Filter> filters)

Specified by:

getTopNHostSummaries in interface FlowRepository

getHostSummaries

public CompletableFuture<List<TrafficSummary<Host>>> getHostSummaries(Set<String> hosts,
                                                                      boolean includeOther,
                                                                      List<Filter> filters)

Specified by:

getHostSummaries in interface FlowRepository

getHostSeries

public CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> getHostSeries(Set<String> hosts,
                                                                                                       long step,
                                                                                                       boolean includeOther,
                                                                                                       List<Filter> filters)

Specified by:

getHostSeries in interface FlowRepository

getTopNHostSeries

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

Specified by:

getTopNHostSeries in interface FlowRepository

resolveHostnameForHost

public CompletableFuture<Host> resolveHostnameForHost(String host,
                                                      List<Filter> filters)

getIdentity

public Identity getIdentity()

getTracerRegistry

public TracerRegistry getTracerRegistry()

start

public void start()

setEnableFlowForwarding

public void setEnableFlowForwarding(boolean enableFlowForwarding)