Package 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.x that allows query and write in a reactive way.
Author:
Jakub Bednar (bednar@github) (20/11/2018 07:08)

  • Method Details

    • getQueryReactiveApi

      @Nonnull QueryReactiveApi getQueryReactiveApi()
      Create a new Query client.
      Returns:
      the new client instance for the Query API

    • getWriteReactiveApi

      @Nonnull WriteReactiveApi getWriteReactiveApi()
      Create a new Write client.
      Returns:
      the new client instance for the Write API

    • getWriteReactiveApi

      @Nonnull WriteReactiveApi getWriteReactiveApi(@Nonnull WriteOptionsReactive writeOptions)
      Create a new Write client.
      Parameters:
      writeOptions - the writes configuration
      Returns:
      the new client instance for the Write API

    • health

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