Index (The RxJava InfluxDB 2.x Client 7.2.0-SNAPSHOT API)

B C D E F G H I J M Q R S W
All Classes and Interfaces|All Packages

B

batchSize(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: Set the number of data point to collect in batch.
build() - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: Build an instance of WriteOptions.
builder() - Static method in class com.influxdb.client.reactive.WriteOptionsReactive: Creates a builder instance.
Builder() - Constructor for class com.influxdb.client.reactive.WriteOptionsReactive.Builder

C

close() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Shutdown and close the client.
com.influxdb.client.reactive - package com.influxdb.client.reactive
com.influxdb.client.reactive.internal - package com.influxdb.client.reactive.internal
computationScheduler(Scheduler) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: Set the scheduler which is used for computational work.
create() - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x client that is configured via influx2.properties.
create(InfluxDBClientOptions) - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x reactive client.
create(String) - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x client.
create(String, char[]) - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x reactive client.
create(String, char[], String) - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x reactive client.
create(String, char[], String, String) - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x reactive client.
create(String, String, char[]) - Static method in class com.influxdb.client.reactive.InfluxDBClientReactiveFactory: Create an instance of the InfluxDB 2.x reactive client.

D

DEFAULTS - Static variable in class com.influxdb.client.reactive.WriteOptionsReactive: Default configuration with values that are consistent with Telegraf.
disableGzip() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Disable Gzip compress for http request body.
disableGzip() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl

E

enableGzip() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Enable Gzip compress for http requests.
enableGzip() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl
exponentialBase(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: The base for the exponential retry delay.

F

flushInterval(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: Set the time to wait at most (milliseconds).

G

getBatchSize() - Method in class com.influxdb.client.reactive.WriteOptionsReactive
getComputationScheduler() - Method in class com.influxdb.client.reactive.WriteOptionsReactive
getExponentialBase() - Method in class com.influxdb.client.reactive.WriteOptionsReactive: The base for the exponential retry delay.
getFlushInterval() - Method in class com.influxdb.client.reactive.WriteOptionsReactive
getJitterInterval() - Method in class com.influxdb.client.reactive.WriteOptionsReactive
getLogLevel() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive
getLogLevel() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl
getMaxRetries() - Method in class com.influxdb.client.reactive.WriteOptionsReactive: The number of max retries when write fails.
getMaxRetryDelay() - Method in class com.influxdb.client.reactive.WriteOptionsReactive: The maximum delay between each retry attempt in milliseconds.
getMaxRetryTime() - Method in class com.influxdb.client.reactive.WriteOptionsReactive: The maximum total retry timeout in milliseconds.
getQueryReactiveApi() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Create a new Query client.
getQueryReactiveApi() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl
getRetryInterval() - Method in class com.influxdb.client.reactive.WriteOptionsReactive: The retry interval is used when the InfluxDB server does not specify "Retry-After" header.
getWriteReactiveApi() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Create a new Write client.
getWriteReactiveApi() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl
getWriteReactiveApi(WriteOptionsReactive) - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Create a new Write client.
getWriteReactiveApi(WriteOptionsReactive) - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl

H

health() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Get the health of an instance.
health() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl

I

InfluxDBClientReactive - Interface in com.influxdb.client.reactive: The reference RxJava client for the InfluxDB 2.x that allows query and write in a reactive way.
InfluxDBClientReactiveFactory - Class in com.influxdb.client.reactive: The Factory that create an instance of a InfluxDB reactive client.
InfluxDBClientReactiveImpl - Class in com.influxdb.client.reactive.internal
InfluxDBClientReactiveImpl(InfluxDBClientOptions) - Constructor for class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl
isGzipEnabled() - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Returns whether Gzip compress for http request body is enabled.
isGzipEnabled() - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl

J

jitterInterval(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: Jitters the batch flush interval by a random amount.

M

maxRetries(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: The number of max retries when write fails.
maxRetryDelay(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: The maximum delay between each retry attempt in milliseconds.
maxRetryTime(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: The maximum total retry timeout in milliseconds.

Q

query(Query) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
query(Query, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
query(Query, String, Class<M>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Execute a Flux against the Flux service.
query(String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
query(String, Class<M>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Execute a Flux against the Flux service.
query(String, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
query(String, String, Class<M>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Execute a Flux against the Flux service.
query(Publisher<String>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
query(Publisher<String>, Class<M>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns the Publisher emitting POJO stream.
query(Publisher<String>, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
query(Publisher<String>, String, Class<M>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns the Publisher emitting POJO stream.
queryQuery(Publisher<Query>, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting FluxRecords which are matched the query.
queryRaw(Query) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
queryRaw(Query, Dialect, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
queryRaw(String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
queryRaw(String, Dialect) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
queryRaw(String, Dialect, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
queryRaw(String, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting raw response fromInfluxDB 2.x server line by line.
queryRaw(Publisher<String>) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response from InfluxDB server line by line.
queryRaw(Publisher<String>, Dialect) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
queryRaw(Publisher<String>, Dialect, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
queryRaw(Publisher<String>, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response from InfluxDB server line by line.
queryRawQuery(Publisher<Query>, Dialect, String) - Method in interface com.influxdb.client.reactive.QueryReactiveApi: Returns Publisher emitting queryRaw response fromInfluxDB 2.x server line by line.
QueryReactiveApi - Interface in com.influxdb.client.reactive: The client that allow perform Flux query against the InfluxDB 2.x by a reactive way.

R

retryInterval(int) - Method in class com.influxdb.client.reactive.WriteOptionsReactive.Builder: Set the the time to wait before retry unsuccessful write (milliseconds).

S

setLogLevel(LogLevel) - Method in interface com.influxdb.client.reactive.InfluxDBClientReactive: Set the log level for the request and response information.
setLogLevel(LogLevel) - Method in class com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl
Success() - Constructor for class com.influxdb.client.reactive.WriteReactiveApi.Success

W

writeMeasurement(WritePrecision, M) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeMeasurement(WritePrecision, M) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Measurement into specified bucket.
writeMeasurement(String, String, WritePrecision, M) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeMeasurement(String, String, WritePrecision, M) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Measurement into specified bucket.
writeMeasurements(WritePrecision, Publisher<M>) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeMeasurements(WritePrecision, Publisher<M>) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Measurements into specified bucket.
writeMeasurements(String, String, WritePrecision, Publisher<M>) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeMeasurements(String, String, WritePrecision, Publisher<M>) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Measurements into specified bucket.
writeMeasurements(Publisher<M>, WriteParameters) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeMeasurements(Publisher<M>, WriteParameters) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Measurements into specified bucket.
WriteOptionsReactive - Class in com.influxdb.client.reactive: The configuration for WriteReactiveApi.
WriteOptionsReactive.Builder - Class in com.influxdb.client.reactive: A builder for WriteOptionsReactive.
writePoint(WritePrecision, Point) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writePoint(WritePrecision, Point) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Data point into specified bucket.
writePoint(String, String, WritePrecision, Point) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writePoint(String, String, WritePrecision, Point) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Data point into specified bucket.
writePoints(WritePrecision, Publisher<Point>) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writePoints(WritePrecision, Publisher<Point>) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Data points into specified bucket.
writePoints(String, String, WritePrecision, Publisher<Point>) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writePoints(String, String, WritePrecision, Publisher<Point>) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Data points into specified bucket.
writePoints(Publisher<Point>, WriteParameters) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writePoints(Publisher<Point>, WriteParameters) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Data points into specified bucket.
WriteReactiveApi - Interface in com.influxdb.client.reactive: Write time-series data into by reactive way InfluxDB 2.x.
WriteReactiveApi.Success - Class in com.influxdb.client.reactive: The class represents a successful written operation.
WriteReactiveApiImpl - Class in com.influxdb.client.reactive.internal
writeRecord(WritePrecision, String) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeRecord(WritePrecision, String) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Line Protocol record into specified bucket.
writeRecord(String, String, WritePrecision, String) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeRecord(String, String, WritePrecision, String) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Line Protocol record into specified bucket.
writeRecords(WritePrecision, Publisher<String>) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeRecords(WritePrecision, Publisher<String>) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Line Protocol records into specified bucket.
writeRecords(String, String, WritePrecision, Publisher<String>) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeRecords(String, String, WritePrecision, Publisher<String>) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Line Protocol records into specified bucket.
writeRecords(Publisher<String>, WriteParameters) - Method in class com.influxdb.client.reactive.internal.WriteReactiveApiImpl
writeRecords(Publisher<String>, WriteParameters) - Method in interface com.influxdb.client.reactive.WriteReactiveApi: Write Line Protocol records into specified bucket.

B C D E F G H I J M Q R S W
All Classes and Interfaces|All Packages