Package org.opennms.netmgt.flows.elastic

Class InitializingFlowRepository

java.lang.Object

org.opennms.netmgt.flows.elastic.InitializingFlowRepository

All Implemented Interfaces:

FlowQueryService, FlowRepository

public class InitializingFlowRepository
extends java.lang.Object
implements FlowRepository

This FlowRepository wrapper will ensure that the repository has been initialized before any *write* calls are made to the given delegate.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InitializingFlowRepository(FlowRepository delegate, io.searchbox.client.JestClient client)
	InitializingFlowRepository(org.osgi.framework.BundleContext bundleContext, FlowRepository delegate, io.searchbox.client.JestClient client, IndexSettings rawIndexSettings, IndexSettings aggIndexSettings)

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)
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)
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)
void	persist(java.util.Collection<Flow> flows, FlowSource source)

Methods inherited from class java.lang.Object

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

Constructor Detail

InitializingFlowRepository

public InitializingFlowRepository(org.osgi.framework.BundleContext bundleContext,
                                  FlowRepository delegate,
                                  io.searchbox.client.JestClient client,
                                  IndexSettings rawIndexSettings,
                                  IndexSettings aggIndexSettings)

InitializingFlowRepository

protected InitializingFlowRepository(FlowRepository delegate,
                                     io.searchbox.client.JestClient client)

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

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

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

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