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

Class InfluxDbTimeSeriesPlugin

java.lang.Object

io.vertigo.database.plugins.timeseries.influxdb.InfluxDbTimeSeriesPlugin

All Implemented Interfaces:

Activeable, CoreComponent, Plugin, TimeSeriesPlugin

public final class InfluxDbTimeSeriesPlugin
extends Object
implements TimeSeriesPlugin, Activeable

Author:

mlaroche

Constructor Summary

Constructors

Constructor	Description
InfluxDbTimeSeriesPlugin(Optional<String> connectorNameOpt, List<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	getFlatTabularTimedData(String appName, List<String> measures, DataFilter dataFilter, TimeFilter timeFilter, Optional<Long> limit)
TabularDatas	getTabularData(String appName, List<String> measures, DataFilter dataFilter, TimeFilter timeFilter, String... groupBy)
TimedDatas	getTabularTimedData(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)
void	start()	Called after the component has been created and filled by injection (for the components built by configuration).
void	stop()	Called before the component is stopped.

Methods inherited from class java.lang.Object

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

Constructor Detail

InfluxDbTimeSeriesPlugin

@Inject
public InfluxDbTimeSeriesPlugin(Optional<String> connectorNameOpt,
                                List<InfluxDbConnector> influxDbConnectors,
                                Optional<String> dbNamesOpt)

Method Detail

start

public void start()

Description copied from interface: Activeable

Called after the component has been created and filled by injection (for the components built by configuration).

Specified by:

start in interface Activeable

stop

public void stop()

Description copied from interface: Activeable

Called before the component is stopped.

Specified by:

stop in interface Activeable

createDatabases

public void createDatabases()

getClusteredTimeSeries

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

Specified by:

getClusteredTimeSeries in interface TimeSeriesPlugin

getFlatTabularTimedData

public TimedDatas getFlatTabularTimedData(String appName,
                                          List<String> measures,
                                          DataFilter dataFilter,
                                          TimeFilter timeFilter,
                                          Optional<Long> limit)

Specified by:

getFlatTabularTimedData in interface TimeSeriesPlugin

getTabularTimedData

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

Specified by:

getTabularTimedData 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