org.opennms.netmgt.flows.elastic

Class ElasticFlowQueryService

java.lang.Object

org.opennms.netmgt.flows.elastic.ElasticFlowQueryService

All Implemented Interfaces:

FlowQueryService

Direct Known Subclasses:

AggregatedFlowQueryService, RawFlowQueryService

public abstract class ElasticFlowQueryService
extends Object
implements FlowQueryService

Constructor Summary

Constructors

Constructor and Description
ElasticFlowQueryService(io.searchbox.client.JestClient client, IndexSelector indexSelector)

Method Summary

Modifier and Type	Method and Description
<T extends io.searchbox.client.JestResult> CompletableFuture<T>	executeAsync(io.searchbox.action.Action<T> action)
CompletableFuture<io.searchbox.core.SearchResult>	searchAsync(String query, TimeRangeFilter timeRangeFilter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opennms.netmgt.flows.api.FlowQueryService

getApplications, getApplicationSeries, getApplicationSummaries, getConversations, getConversationSeries, getConversationSummaries, getFlowCount, getHosts, getHostSeries, getHostSummaries, getTopNApplicationSeries, getTopNApplicationSummaries, getTopNConversationSeries, getTopNConversationSummaries, getTopNHostSeries, getTopNHostSummaries

Constructor Detail

ElasticFlowQueryService

public ElasticFlowQueryService(io.searchbox.client.JestClient client,
                               IndexSelector indexSelector)

Method Detail

searchAsync

public CompletableFuture<io.searchbox.core.SearchResult> searchAsync(String query,
                                                                     TimeRangeFilter timeRangeFilter)

executeAsync

public <T extends io.searchbox.client.JestResult> CompletableFuture<T> executeAsync(io.searchbox.action.Action<T> action)