Class RawFlowQueryService

    • Constructor Detail

      • RawFlowQueryService

        public RawFlowQueryService​(io.searchbox.client.JestClient client,
                                   IndexSelector indexSelector)
    • Method Detail

      • getFlowCount

        public java.util.concurrent.CompletableFuture<java.lang.Long> getFlowCount​(java.util.List<Filter> filters)
      • getApplications

        public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getApplications​(java.lang.String matchingPrefix,
                                                                                                        long limit,
                                                                                                        java.util.List<Filter> filters)
      • getTopNApplicationSummaries

        public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<java.lang.String>>> getTopNApplicationSummaries​(int N,
                                                                                                                                    boolean includeOther,
                                                                                                                                    java.util.List<Filter> filters)
      • 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)
      • 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)
      • 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)
      • 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)
      • getTopNConversationSummaries

        public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Conversation>>> getTopNConversationSummaries​(int N,
                                                                                                                                 boolean includeOther,
                                                                                                                                 java.util.List<Filter> filters)
      • 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)
      • 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)
      • 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)
      • getHosts

        public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getHosts​(java.lang.String regex,
                                                                                                 long limit,
                                                                                                 java.util.List<Filter> filters)
      • getTopNHostSummaries

        public java.util.concurrent.CompletableFuture<java.util.List<TrafficSummary<Host>>> getTopNHostSummaries​(int N,
                                                                                                                 boolean includeOther,
                                                                                                                 java.util.List<Filter> filters)
      • 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)
      • 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)
      • 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)
      • getFieldValues

        public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> getFieldValues​(LimitedCardinalityField field,
                                                                                                       java.util.List<Filter> filters)
      • getFieldSeries

        public 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)
      • resolveHostnameForConversation

        public java.util.concurrent.CompletableFuture<Conversation> resolveHostnameForConversation​(java.lang.String convoKey,
                                                                                                   java.util.List<Filter> filters)
      • resolveHostnameForHost

        public java.util.concurrent.CompletableFuture<Host> resolveHostnameForHost​(java.lang.String host,
                                                                                   java.util.List<Filter> filters)