Package 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, pingService, retrofit

Constructor Summary

Constructors

Constructor	Description
InfluxDBClientReactiveImpl(InfluxDBClientOptions options)

Method Summary

Modifier and Type	Method	Description
InfluxDBClientReactive	disableGzip()	Disable Gzip compress for http request body.
InfluxDBClientReactive	enableGzip()	Enable Gzip compress for http requests.
com.influxdb.LogLevel	getLogLevel()
QueryReactiveApi	getQueryReactiveApi()	Create a new Query client.
WriteReactiveApi	getWriteReactiveApi()	Create a new Write client.
WriteReactiveApi	getWriteReactiveApi(WriteOptionsReactive writeOptions)	Create a new Write client.
org.reactivestreams.Publisher<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, ping, responseToError, setLogLevel, toInfluxException, version

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 Details

InfluxDBClientReactiveImpl

public InfluxDBClientReactiveImpl(@Nonnull
 InfluxDBClientOptions options)

Method Details

getQueryReactiveApi

@Nonnull
public QueryReactiveApi getQueryReactiveApi()

Description copied from interface: InfluxDBClientReactive

Create a new 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

Create a new Write client.

Specified by:

getWriteReactiveApi in interface InfluxDBClientReactive

Returns:

the new client instance for the Write API

getWriteReactiveApi

@Nonnull
public WriteReactiveApi getWriteReactiveApi(@Nonnull
 WriteOptionsReactive writeOptions)

Description copied from interface: InfluxDBClientReactive

Create a new Write client.

Specified by:

getWriteReactiveApi in interface InfluxDBClientReactive

Parameters:

writeOptions - the writes configuration

Returns:

the new client instance for the Write API

health

@Nonnull
public org.reactivestreams.Publisher<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.