org.opennms.netmgt.flows.api

Interface FlowRepository

All Known Implementing Classes:

ElasticFlowRepository, InitializingFlowRepository

public interface FlowRepository

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> packets, FlowSource source)

Method Detail

persist

void persist(Collection<Flow> packets,
             FlowSource source)
      throws FlowException

Throws:

FlowException

getFlowCount

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

getTopNApplications

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

getTopNApplicationsSeries

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

getTopNConversations

CompletableFuture<List<TrafficSummary<ConversationKey>>> getTopNConversations(int N,
                                                                              List<Filter> filters)

getTopNConversationsSeries

CompletableFuture<com.google.common.collect.Table<Directional<ConversationKey>,Long,Double>> getTopNConversationsSeries(int N,
                                                                                                                        long step,
                                                                                                                        List<Filter> filters)