influxdb-client-kotlin/com.influxdb.client.kotlin/QueryKotlinApi

QueryKotlinApi

interface QueryKotlinApi(source)

The client that allows perform Flux queries against the InfluxDB /api/v2/query endpoint.

For parametrized queries use Query object, see com.influxdb.client.QueryApi in Java module for more details.

Author

Jakub Bednar (bednar@github) (29/10/2018 10:45)

Functions

Link copied to clipboard
abstract fun query(query: Query): Channel<FluxRecord>
abstract fun query(query: String): Channel<FluxRecord>
abstract fun query(query: Query, org: String): Channel<FluxRecord>
abstract fun query(query: String, org: String): Channel<FluxRecord>

Executes the Flux query against the InfluxDB and asynchronously stream com.influxdb.query.FluxRecords to kotlinx.coroutines.channels.Channel.

abstract fun <M> query(query: Query, measurementType: Class<M>): Channel<M>
abstract fun <M> query(query: String, measurementType: Class<M>): Channel<M>
abstract fun <M> query(query: Query, org: String, measurementType: Class<M>): Channel<M>
abstract fun <M> query(query: String, org: String, measurementType: Class<M>): Channel<M>

Executes the Flux query against the InfluxDB and asynchronously stream measurements to kotlinx.coroutines.channels.Channel.

Link copied to clipboard
abstract fun queryRaw(query: Query): Channel<String>
abstract fun queryRaw(query: String): Channel<String>
abstract fun queryRaw(query: Query, org: String): Channel<String>
abstract fun queryRaw(query: String, dialect: Dialect): Channel<String>
abstract fun queryRaw(query: String, org: String): Channel<String>
abstract fun queryRaw(query: String, dialect: Dialect, org: String): Channel<String>

Executes the Flux query against the InfluxDB and asynchronously stream response to kotlinx.coroutines.channels.Channel.