[+] Add prefs field in influx
This commit is contained in:
@@ -67,6 +67,7 @@ interface Prefs {
|
|||||||
data class Influx(
|
data class Influx(
|
||||||
val kt: InfluxDBClientKotlin,
|
val kt: InfluxDBClientKotlin,
|
||||||
val java: InfluxDBClient,
|
val java: InfluxDBClient,
|
||||||
|
val prefs: Prefs,
|
||||||
|
|
||||||
val prec: WritePrecision = WritePrecision.MS
|
val prec: WritePrecision = WritePrecision.MS
|
||||||
) {
|
) {
|
||||||
@@ -98,6 +99,7 @@ val Context.prefs get() = object : Prefs {
|
|||||||
override fun createInflux() = Influx(
|
override fun createInflux() = Influx(
|
||||||
InfluxDBClientKotlinFactory.create(infUrl!!, infToken!!.toCharArray(), infOrg!!, infBucket!!),
|
InfluxDBClientKotlinFactory.create(infUrl!!, infToken!!.toCharArray(), infOrg!!, infBucket!!),
|
||||||
InfluxDBClientFactory.create(infUrl!!, infToken!!.toCharArray(), infOrg!!, infBucket!!),
|
InfluxDBClientFactory.create(infUrl!!, infToken!!.toCharArray(), infOrg!!, infBucket!!),
|
||||||
|
this
|
||||||
)
|
)
|
||||||
|
|
||||||
override suspend fun influxPing() = with(createInflux()) {
|
override suspend fun influxPing() = with(createInflux()) {
|
||||||
@@ -170,4 +172,4 @@ object Database {
|
|||||||
|
|
||||||
val Cursor.iterator get() = CursorIterator(this)
|
val Cursor.iterator get() = CursorIterator(this)
|
||||||
val Cursor.seq get() = iterator.asSequence()
|
val Cursor.seq get() = iterator.asSequence()
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user