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 Details

FluxInfluxDbTimeSeriesPlugin

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

Method Details

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