Package com.influxdb.client.reactive

Interface WriteReactiveApi

All Known Implementing Classes:
WriteReactiveApiImpl
@ThreadSafe public interface WriteReactiveApi
Write time-series data into by reactive way InfluxDB 2.x.

The data are formatted in Line Protocol.

Author:
Jakub Bednar (bednar@github) (22/11/2018 06:49)

  • Method Details

    • writeRecord

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecord(@Nonnull WritePrecision precision, @Nullable String record)
      Write Line Protocol record into specified bucket.

      The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

      Parameters:
      precision - specifies the precision for the unix timestamps within the body line-protocol
      record - specifies the record in InfluxDB Line Protocol.
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeRecord

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecord(@Nonnull String bucket, @Nonnull String org, @Nonnull WritePrecision precision, @Nullable String record)
      Write Line Protocol record into specified bucket.
      Parameters:
      bucket - specifies the destination bucket for writes
      org - specifies the destination organization for writes
      precision - specifies the precision for the unix timestamps within the body line-protocol
      record - specifies the record in InfluxDB Line Protocol.
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeRecords

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecords(@Nonnull WritePrecision precision, @Nonnull org.reactivestreams.Publisher<String> records)
      Write Line Protocol records into specified bucket.

      The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

      Parameters:
      precision - specifies the precision for the unix timestamps within the body line-protocol
      records - specifies the records in InfluxDB Line Protocol
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeRecords

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecords(@Nonnull String bucket, @Nonnull String org, @Nonnull WritePrecision precision, @Nonnull org.reactivestreams.Publisher<String> records)
      Write Line Protocol records into specified bucket.
      Parameters:
      bucket - specifies the destination bucket for writes
      org - specifies the destination organization for writes
      precision - specifies the precision for the unix timestamps within the body line-protocol
      records - specifies the records in InfluxDB Line Protocol
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeRecords

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writeRecords(@Nonnull org.reactivestreams.Publisher<String> records, @Nonnull WriteParameters parameters)
      Write Line Protocol records into specified bucket.
      Parameters:
      records - specifies the records in InfluxDB Line Protocol
      parameters - specify InfluxDB Write endpoint parameters
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writePoint

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoint(@Nonnull WritePrecision precision, @Nonnull Point point)
      Write Data point into specified bucket.

      The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

      Parameters:
      precision - specifies the precision for the unix timestamps within the body line-protocol
      point - specifies the Data point to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writePoint

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoint(@Nonnull String bucket, @Nonnull String org, @Nonnull WritePrecision precision, @Nonnull Point point)
      Write Data point into specified bucket.
      Parameters:
      bucket - specifies the destination bucket for writes
      org - specifies the destination organization for writes
      precision - specifies the precision for the unix timestamps within the body line-protocol
      point - specifies the Data point to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writePoints

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoints(@Nonnull WritePrecision precision, @Nonnull org.reactivestreams.Publisher<Point> points)
      Write Data points into specified bucket.

      The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

      Parameters:
      precision - specifies the precision for the unix timestamps within the body line-protocol
      points - specifies the Data points to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writePoints

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoints(@Nonnull String bucket, @Nonnull String org, @Nonnull WritePrecision precision, @Nonnull org.reactivestreams.Publisher<Point> points)
      Write Data points into specified bucket.
      Parameters:
      bucket - specifies the destination bucket ID for writes
      org - specifies the destination organization ID for writes
      precision - specifies the precision for the unix timestamps within the body line-protocol
      points - specifies the Data points to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writePoints

      org.reactivestreams.Publisher<WriteReactiveApi.Success> writePoints(@Nonnull org.reactivestreams.Publisher<Point> points, @Nonnull WriteParameters parameters)
      Write Data points into specified bucket.
      Parameters:
      points - specifies the Data points to write into bucket
      parameters - specify InfluxDB Write endpoint parameters
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeMeasurement

      <M> org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurement(@Nonnull WritePrecision precision, @Nonnull M measurement)
      Write Measurement into specified bucket.

      The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

      Type Parameters:
      M - type of measurement
      Parameters:
      precision - specifies the precision for the unix timestamps within the body line-protocol
      measurement - specifies the Measurement to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeMeasurement

      <M> org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurement(@Nonnull String bucket, @Nonnull String org, @Nonnull WritePrecision precision, @Nonnull M measurement)
      Write Measurement into specified bucket.
      Type Parameters:
      M - type of measurement
      Parameters:
      bucket - specifies the destination bucket for writes
      org - specifies the destination organization for writes
      precision - specifies the precision for the unix timestamps within the body line-protocol
      measurement - specifies the Measurement to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeMeasurements

      <M> org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurements(@Nonnull WritePrecision precision, @Nonnull org.reactivestreams.Publisher<M> measurements)
      Write Measurements into specified bucket.

      The InfluxDBClientOptions.getBucket() will be use as destination bucket and InfluxDBClientOptions.getOrg() will be used as destination organization.

      Type Parameters:
      M - type of measurement
      Parameters:
      precision - specifies the precision for the unix timestamps within the body line-protocol
      measurements - specifies the Measurements to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeMeasurements

      <M> org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurements(@Nonnull String bucket, @Nonnull String org, @Nonnull WritePrecision precision, @Nonnull org.reactivestreams.Publisher<M> measurements)
      Write Measurements into specified bucket.
      Type Parameters:
      M - type of measurement
      Parameters:
      bucket - specifies the destination bucket for writes
      org - specifies the destination organization for writes
      precision - specifies the precision for the unix timestamps within the body line-protocol
      measurements - specifies the Measurements to write into bucket
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)

    • writeMeasurements

      <M> org.reactivestreams.Publisher<WriteReactiveApi.Success> writeMeasurements(@Nonnull org.reactivestreams.Publisher<M> measurements, @Nonnull WriteParameters parameters)
      Write Measurements into specified bucket.
      Type Parameters:
      M - type of measurement
      Parameters:
      measurements - specifies the Measurements to write into bucket
      parameters - specify InfluxDB Write endpoint parameters
      Returns:
      Publisher representing a successful written operation or signal the InfluxException via Subscriber.onError(java.lang.Throwable)