com.influxdb.client.reactive

Interface InfluxDBClientReactive

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

InfluxDBClientReactiveImpl

public interface InfluxDBClientReactive
extends AutoCloseable

The reference RxJava client for the InfluxDB 2.0 that allows query and write in a reactive way.

Author:

Jakub Bednar (bednar@github) (20/11/2018 07:08)

Method Summary

Modifier and Type	Method and Description
void	close() Shutdown and close the client.
InfluxDBClientReactive	disableGzip() Disable Gzip compress for http request body.
InfluxDBClientReactive	enableGzip() Enable Gzip compress for http requests.
com.influxdb.LogLevel	getLogLevel()
QueryReactiveApi	getQueryReactiveApi() Get the Query client.
WriteReactiveApi	getWriteReactiveApi() Get the Write client.
WriteReactiveApi	getWriteReactiveApi(WriteOptions writeOptions) Get the Write client.
io.reactivex.Single<HealthCheck>	health() Get the health of an instance.
boolean	isGzipEnabled() Returns whether Gzip compress for http request body is enabled.
InfluxDBClientReactive	setLogLevel(com.influxdb.LogLevel logLevel) Set the log level for the request and response information.

Method Detail

getQueryReactiveApi

@Nonnull
QueryReactiveApi getQueryReactiveApi()

Get the Query client.

Returns:

the new client instance for the Query API

getWriteReactiveApi

@Nonnull
WriteReactiveApi getWriteReactiveApi()

Get the Write client.

Returns:

the new client instance for the Write API

getWriteReactiveApi

@Nonnull
WriteReactiveApi getWriteReactiveApi(@Nonnull
                                              WriteOptions writeOptions)

Get the Write client.

Returns:

the new client instance for the Write API

health

@Nonnull
io.reactivex.Single<HealthCheck> health()

Get the health of an instance.

Returns:

health of an instance

getLogLevel

@Nonnull
com.influxdb.LogLevel getLogLevel()

Returns:

the LogLevel that is used for logging requests and responses

setLogLevel

@Nonnull
InfluxDBClientReactive setLogLevel(@Nonnull
                                            com.influxdb.LogLevel logLevel)

Set the log level for the request and response information.

Parameters:

logLevel - the log level to set.

Returns:

the InfluxDBClient instance to be able to use it in a fluent manner.

enableGzip

@Nonnull
InfluxDBClientReactive enableGzip()

Enable Gzip compress for http requests. Currently only the "Write" and "Query" endpoints supports the Gzip compression.

Returns:

the InfluxDBClient instance to be able to use it in a fluent manner.

disableGzip

@Nonnull
InfluxDBClientReactive disableGzip()

Disable Gzip compress for http request body.

Returns:

the InfluxDBClient instance to be able to use it in a fluent manner.

isGzipEnabled

boolean isGzipEnabled()

Returns whether Gzip compress for http request body is enabled.

Returns:

true if gzip is enabled.

close

void close()

Shutdown and close the client.

Specified by:

close in interface AutoCloseable