Package org.opennms.netmgt.flows.api
Interface FlowQueryService
-
- All Known Implementing Classes:
AggregatedFlowQueryService
,ElasticFlowQueryService
,RawFlowQueryService
,SmartQueryService
public interface FlowQueryService
Used to query statistics and time series derived from flow data.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>>
getFieldSeries(LimitedCardinalityField field, long step, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>>
getFieldSummaries(LimitedCardinalityField field, java.util.List<Filter> filters)
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>
getFieldValues(LimitedCardinalityField field, 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)
-
-
-
Method Detail
-
getFlowCount
java.util.concurrent.CompletableFuture<java.lang.Long> getFlowCount(java.util.List<Filter> filters)
-
getApplications
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getApplications(java.lang.String matchingPrefix, long limit, java.util.List<Filter> filters)
-
getTopNApplicationSummaries
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getTopNApplicationSummaries(int N, boolean includeOther, java.util.List<Filter> filters)
-
getApplicationSummaries
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)
-
getApplicationSeries
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)
-
getTopNApplicationSeries
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)
-
getConversations
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)
-
getTopNConversationSummaries
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>> getTopNConversationSummaries(int N, boolean includeOther, java.util.List<Filter> filters)
-
getConversationSummaries
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>> getConversationSummaries(java.util.Set<java.lang.String> conversations, boolean includeOther, java.util.List<Filter> filters)
-
getConversationSeries
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)
-
getTopNConversationSeries
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)
-
getHosts
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getHosts(java.lang.String regex, long limit, java.util.List<Filter> filters)
-
getTopNHostSummaries
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>> getTopNHostSummaries(int N, boolean includeOther, java.util.List<Filter> filters)
-
getHostSummaries
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>> getHostSummaries(java.util.Set<java.lang.String> hosts, boolean includeOther, java.util.List<Filter> filters)
-
getHostSeries
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)
-
getTopNHostSeries
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)
-
getFieldValues
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getFieldValues(LimitedCardinalityField field, java.util.List<Filter> filters)
-
getFieldSummaries
java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getFieldSummaries(LimitedCardinalityField field, java.util.List<Filter> filters)
-
getFieldSeries
java.util.concurrent.CompletableFuture<com.google.common.collect.Table<Directional<java.lang.String>,java.lang.Long,java.lang.Double>> getFieldSeries(LimitedCardinalityField field, long step, java.util.List<Filter> filters)
-
-