ch.algotrader.influxdb

Class InfluxDBAdapter

java.lang.Object

ch.algotrader.influxdb.InfluxDBAdapter

public class InfluxDBAdapter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
InfluxDBAdapter(InfluxDBConfig config, java.util.concurrent.ScheduledExecutorService healthCheckExecutor)

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	dropMeasurement(java.lang.String mesurement)
void	flush()
InfluxDB	getDB()
QueryResult	query(java.lang.String queryString)
void	query(java.lang.String queryString, int chunkSize, java.util.function.BiConsumer<InfluxDB.Cancellable,QueryResult> consumer, java.lang.Runnable onComplete)
void	query(java.lang.String queryString, int chunkSize, java.util.function.BiConsumer<InfluxDB.Cancellable,QueryResult> consumer, java.lang.Runnable onComplete, java.util.function.Consumer<java.lang.Throwable> onFailure)
void	query(java.lang.String queryString, int chunkSize, java.util.function.Consumer<QueryResult> consumer)
void	save(Point point)

Methods inherited from class java.lang.Object

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

Constructor Detail

InfluxDBAdapter

public InfluxDBAdapter(InfluxDBConfig config,
                       java.util.concurrent.ScheduledExecutorService healthCheckExecutor)

Method Detail

save

public void save(Point point)

query

public QueryResult query(java.lang.String queryString)

query

public void query(java.lang.String queryString,
                  int chunkSize,
                  java.util.function.Consumer<QueryResult> consumer)

query

public void query(java.lang.String queryString,
                  int chunkSize,
                  java.util.function.BiConsumer<InfluxDB.Cancellable,QueryResult> consumer,
                  java.lang.Runnable onComplete)

query

public void query(java.lang.String queryString,
                  int chunkSize,
                  java.util.function.BiConsumer<InfluxDB.Cancellable,QueryResult> consumer,
                  java.lang.Runnable onComplete,
                  java.util.function.Consumer<java.lang.Throwable> onFailure)

dropMeasurement

public void dropMeasurement(java.lang.String mesurement)

destroy

public void destroy()

getDB

public InfluxDB getDB()

flush

public void flush()