org.opennms.netmgt.flows.elastic

Class InitializingFlowRepository

java.lang.Object

org.opennms.netmgt.flows.elastic.InitializingFlowRepository

All Implemented Interfaces:

FlowRepository

public class InitializingFlowRepository
extends 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 and Description
	InitializingFlowRepository(org.osgi.framework.BundleContext bundleContext, FlowRepository delegate, io.searchbox.client.JestClient client, IndexSettings indexSettings)
protected	InitializingFlowRepository(FlowRepository delegate, io.searchbox.client.JestClient client)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Long>	getFlowCount(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<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)
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

Constructor Detail

InitializingFlowRepository

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

InitializingFlowRepository

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

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

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