org.opennms.netmgt.flows.api

Interface FlowQueryService

All Known Subinterfaces:

FlowRepository

All Known Implementing Classes:

AggregatedFlowQueryService, ElasticFlowQueryService, ElasticFlowRepository, InitializingFlowRepository, RawFlowQueryService, SmartQueryService

public interface FlowQueryService

Used to query statistics and time series derived from flow data.

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)
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)

Method Detail

getFlowCount

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

getApplications

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

getTopNApplicationSummaries

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

getApplicationSummaries

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

getApplicationSeries

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

getTopNApplicationSeries

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

getConversations

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

getTopNConversationSummaries

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

getConversationSummaries

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

getConversationSeries

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

getTopNConversationSeries

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

getHosts

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

getTopNHostSummaries

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

getHostSummaries

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

getHostSeries

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

getTopNHostSeries

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