Package org.opennms.netmgt.flows.elastic

Class ElasticFlowRepository

java.lang.Object

org.opennms.netmgt.flows.elastic.ElasticFlowRepository

All Implemented Interfaces:

FlowQueryService, 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, SmartQueryService smartQueryService)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	getApplications(java.lang.String matchingPrefix, long limit, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>>	getApplicationSeries(java.util.Set<java.lang.String> applications, long step, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>>	getApplicationSummaries(java.util.Set<java.lang.String> applications, boolean includeOther, java.util.List<Filter> filters)
int	getBulkRetryCount()
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	getConversations(java.lang.String locationPattern, java.lang.String protocolPattern, java.lang.String lowerIPPattern, java.lang.String upperIPPattern, java.lang.String applicationPattern, long limit, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,java.lang.Long,java.lang.Double>>	getConversationSeries(java.util.Set<java.lang.String> conversations, long step, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>>	getConversationSummaries(java.util.Set<java.lang.String> conversations, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.lang.Long>	getFlowCount(java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	getHosts(java.lang.String regex, long limit, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Host>,java.lang.Long,java.lang.Double>>	getHostSeries(java.util.Set<java.lang.String> hosts, long step, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>>	getHostSummaries(java.util.Set<java.lang.String> hosts, boolean includeOther, java.util.List<Filter> filters)
Identity	getIdentity()
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>>	getTopNApplicationSeries(int N, long step, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>>	getTopNApplicationSummaries(int N, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,java.lang.Long,java.lang.Double>>	getTopNConversationSeries(int N, long step, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>>	getTopNConversationSummaries(int N, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<Host>,java.lang.Long,java.lang.Double>>	getTopNHostSeries(int N, long step, boolean includeOther, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>>	getTopNHostSummaries(int N, boolean includeOther, java.util.List<Filter> filters)
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,
                             SmartQueryService smartQueryService)

Method Detail

persist

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

Specified by:

persist in interface FlowRepository

Throws:

FlowException

getFlowCount

public java.util.concurrent.CompletableFuture<java.lang.Long> getFlowCount(java.util.List<Filter> filters)

Specified by:

getFlowCount in interface FlowQueryService

getApplications

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getApplications(java.lang.String matchingPrefix,
                                                                                                long limit,
                                                                                                java.util.List<Filter> filters)

Specified by:

getApplications in interface FlowQueryService

getTopNApplicationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getTopNApplicationSummaries(int N,
                                                                                                                            boolean includeOther,
                                                                                                                            java.util.List<Filter> filters)

Specified by:

getTopNApplicationSummaries in interface FlowQueryService

getApplicationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getApplicationSummaries(java.util.Set<java.lang.String> applications,
                                                                                                                        boolean includeOther,
                                                                                                                        java.util.List<Filter> filters)

Specified by:

getApplicationSummaries in interface FlowQueryService

getApplicationSeries

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

Specified by:

getApplicationSeries in interface FlowQueryService

getTopNApplicationSeries

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

Specified by:

getTopNApplicationSeries in interface FlowQueryService

getConversations

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getConversations(java.lang.String locationPattern,
                                                                                                 java.lang.String protocolPattern,
                                                                                                 java.lang.String lowerIPPattern,
                                                                                                 java.lang.String upperIPPattern,
                                                                                                 java.lang.String applicationPattern,
                                                                                                 long limit,
                                                                                                 java.util.List<Filter> filters)

Specified by:

getConversations in interface FlowQueryService

getTopNConversationSummaries

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

Specified by:

getTopNConversationSummaries in interface FlowQueryService

getConversationSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>> getConversationSummaries(java.util.Set<java.lang.String> conversations,
                                                                                                                     boolean includeOther,
                                                                                                                     java.util.List<Filter> filters)

Specified by:

getConversationSummaries in interface FlowQueryService

getConversationSeries

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

Specified by:

getConversationSeries in interface FlowQueryService

getTopNConversationSeries

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

Specified by:

getTopNConversationSeries in interface FlowQueryService

getHosts

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getHosts(java.lang.String regex,
                                                                                         long limit,
                                                                                         java.util.List<Filter> filters)

Specified by:

getHosts in interface FlowQueryService

getTopNHostSummaries

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

Specified by:

getTopNHostSummaries in interface FlowQueryService

getHostSummaries

public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>> getHostSummaries(java.util.Set<java.lang.String> hosts,
                                                                                                     boolean includeOther,
                                                                                                     java.util.List<Filter> filters)

Specified by:

getHostSummaries in interface FlowQueryService

getHostSeries

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

Specified by:

getHostSeries in interface FlowQueryService

getTopNHostSeries

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

Specified by:

getTopNHostSeries in interface FlowQueryService

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)