com.influxdb.client.reactive.internal

Class InfluxDBClientReactiveImpl

java.lang.Object

com.influxdb.internal.AbstractRestClient

com.influxdb.client.internal.AbstractInfluxDBClient

com.influxdb.client.reactive.internal.InfluxDBClientReactiveImpl

All Implemented Interfaces:

InfluxDBClientReactive, AutoCloseable

public class InfluxDBClientReactiveImpl
extends AbstractInfluxDBClient
implements InfluxDBClientReactive

Author:

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

Field Summary

Fields inherited from class com.influxdb.client.internal.AbstractInfluxDBClient

autoCloseables, DEFAULT_DIALECT, gzipInterceptor, healthService, loggingInterceptor, options, retrofit

Constructor Summary

Constructors

Constructor and Description
InfluxDBClientReactiveImpl(InfluxDBClientOptions options)

Method Summary

Modifier and Type	Method and Description
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.

Methods inherited from class com.influxdb.client.internal.AbstractInfluxDBClient

close, health

Methods inherited from class com.influxdb.internal.AbstractRestClient

execute, getLogLevel, responseToError, setLogLevel

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.influxdb.client.reactive.InfluxDBClientReactive

close

Constructor Detail

InfluxDBClientReactiveImpl

public InfluxDBClientReactiveImpl(@Nonnull
                                  InfluxDBClientOptions options)

Method Detail

getQueryReactiveApi

@Nonnull
public QueryReactiveApi getQueryReactiveApi()

Description copied from interface: InfluxDBClientReactive

Get the Query client.

Specified by:

getQueryReactiveApi in interface InfluxDBClientReactive

Returns:

the new client instance for the Query API

getWriteReactiveApi

@Nonnull
public WriteReactiveApi getWriteReactiveApi()

Description copied from interface: InfluxDBClientReactive

Get the Write client.

Specified by:

getWriteReactiveApi in interface InfluxDBClientReactive

Returns:

the new client instance for the Write API

getWriteReactiveApi

@Nonnull
public WriteReactiveApi getWriteReactiveApi(@Nonnull
                                                     WriteOptions writeOptions)

Description copied from interface: InfluxDBClientReactive

Get the Write client.

Specified by:

getWriteReactiveApi in interface InfluxDBClientReactive

Returns:

the new client instance for the Write API

health

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

Description copied from interface: InfluxDBClientReactive

Get the health of an instance.

Specified by:

health in interface InfluxDBClientReactive

Returns:

health of an instance

getLogLevel

@Nonnull
public com.influxdb.LogLevel getLogLevel()

Specified by:

getLogLevel in interface InfluxDBClientReactive

Returns:

the LogLevel that is used for logging requests and responses

setLogLevel

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

Description copied from interface: InfluxDBClientReactive

Set the log level for the request and response information.

Specified by:

setLogLevel in interface InfluxDBClientReactive

Parameters:

logLevel - the log level to set.

Returns:

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

enableGzip

@Nonnull
public InfluxDBClientReactive enableGzip()

Description copied from interface: InfluxDBClientReactive

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

Specified by:

enableGzip in interface InfluxDBClientReactive

Returns:

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

disableGzip

@Nonnull
public InfluxDBClientReactive disableGzip()

Description copied from interface: InfluxDBClientReactive

Disable Gzip compress for http request body.

Specified by:

disableGzip in interface InfluxDBClientReactive

Returns:

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

isGzipEnabled

public boolean isGzipEnabled()

Description copied from interface: InfluxDBClientReactive

Returns whether Gzip compress for http request body is enabled.

Specified by:

isGzipEnabled in interface InfluxDBClientReactive

Returns:

true if gzip is enabled.