Package io.vertigo.database.plugins.timeseries.influxdb

Class FluxInfluxDbTimeSeriesPlugin

java.lang.Object

io.vertigo.database.plugins.timeseries.influxdb.FluxInfluxDbTimeSeriesPlugin

All Implemented Interfaces:

io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, TimeSeriesPlugin

public final class FluxInfluxDbTimeSeriesPlugin
extends Object
implements TimeSeriesPlugin

Author:

mlaroche

Constructor Summary

Constructors

Constructor	Description
FluxInfluxDbTimeSeriesPlugin(Optional<String> connectorNameOpt, List<io.vertigo.connectors.influxdb.InfluxDbConnector> influxDbConnectors, Optional<String> dbNamesOpt)

Method Summary

Modifier and Type	Method	Description
void	createDatabases()
TimedDatas	getClusteredTimeSeries(String appName, ClusteredMeasure clusteredMeasure, DataFilter dataFilter, TimeFilter timeFilter)
List<String>	getDbNames()
TimedDatas	getLastTabularDatas(String appName, List<String> measures, DataFilter dataFilter, TimeFilter timeFilter, String... groupBy)
TabularDatas	getTabularData(String appName, List<String> measures, DataFilter dataFilter, TimeFilter timeFilter, String... groupBy)
List<String>	getTagValues(String appName, String measurement, String tag)
TimedDatas	getTimeSeries(String appName, List<String> measures, DataFilter dataFilter, TimeFilter timeFilter)
TabularDatas	getTops(String appName, String measure, DataFilter dataFilter, TimeFilter timeFilter, String groupBy, int maxRows)
void	insertMeasure(String dbName, Measure measure)
void	insertMeasures(String dbName, List<Measure> measures)

Methods inherited from class java.lang.Object

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

Constructor Detail

FluxInfluxDbTimeSeriesPlugin

@Inject
public FluxInfluxDbTimeSeriesPlugin(Optional<String> connectorNameOpt,
                                    List<io.vertigo.connectors.influxdb.InfluxDbConnector> influxDbConnectors,
                                    Optional<String> dbNamesOpt)

Method Detail

createDatabases

public void createDatabases()

getClusteredTimeSeries

public TimedDatas getClusteredTimeSeries(String appName,
                                         ClusteredMeasure clusteredMeasure,
                                         DataFilter dataFilter,
                                         TimeFilter timeFilter)

Specified by:

getClusteredTimeSeries in interface TimeSeriesPlugin

getLastTabularDatas

public TimedDatas getLastTabularDatas(String appName,
                                      List<String> measures,
                                      DataFilter dataFilter,
                                      TimeFilter timeFilter,
                                      String... groupBy)

Specified by:

getLastTabularDatas in interface TimeSeriesPlugin

getTabularData

public TabularDatas getTabularData(String appName,
                                   List<String> measures,
                                   DataFilter dataFilter,
                                   TimeFilter timeFilter,
                                   String... groupBy)

Specified by:

getTabularData in interface TimeSeriesPlugin

getTagValues

public List<String> getTagValues(String appName,
                                 String measurement,
                                 String tag)

Specified by:

getTagValues in interface TimeSeriesPlugin

getTimeSeries

public TimedDatas getTimeSeries(String appName,
                                List<String> measures,
                                DataFilter dataFilter,
                                TimeFilter timeFilter)

Specified by:

getTimeSeries in interface TimeSeriesPlugin

getTops

public TabularDatas getTops(String appName,
                            String measure,
                            DataFilter dataFilter,
                            TimeFilter timeFilter,
                            String groupBy,
                            int maxRows)

Specified by:

getTops in interface TimeSeriesPlugin

insertMeasure

public void insertMeasure(String dbName,
                          Measure measure)

Specified by:

insertMeasure in interface TimeSeriesPlugin

insertMeasures

public void insertMeasures(String dbName,
                           List<Measure> measures)

Specified by:

insertMeasures in interface TimeSeriesPlugin

getDbNames

public List<String> getDbNames()

Specified by:

getDbNames in interface TimeSeriesPlugin