com.influxdb.client.reactive

Interface WriteReactiveApi

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

WriteReactiveApiImpl

@ThreadSafe
public interface WriteReactiveApi
extends AutoCloseable

Write time-series data into InfluxDB 2.0.

The data are formatted in Line Protocol.

Author:

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

Method Summary

Modifier and Type	Method and Description
void	close() Close threads for asynchronous batch writing.
<T extends AbstractWriteEvent> io.reactivex.Observable<T>	listenEvents(Class<T> eventType) Listen the events produced by WriteApi.
<M> void	writeMeasurement(String bucket, String org, WritePrecision precision, io.reactivex.Maybe<M> measurement) Write Measurement into specified bucket.
<M> void	writeMeasurement(WritePrecision precision, io.reactivex.Maybe<M> measurement) Write Measurement into specified bucket.
<M> void	writeMeasurements(String bucket, String org, WritePrecision precision, io.reactivex.Flowable<M> measurements) Write Measurements into specified bucket.
<M> void	writeMeasurements(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<M> measurements) Write Measurements into specified bucket.
<M> void	writeMeasurements(WritePrecision precision, io.reactivex.Flowable<M> measurements) Write Measurements into specified bucket.
<M> void	writeMeasurements(WritePrecision precision, org.reactivestreams.Publisher<M> measurements) Write Measurements into specified bucket.
void	writePoint(io.reactivex.Maybe<Point> point) Write Data point into specified bucket.
void	writePoint(String bucket, String org, io.reactivex.Maybe<Point> point) Write Data point into specified bucket.
void	writePoints(io.reactivex.Flowable<Point> points) Write Data points into specified bucket.
void	writePoints(org.reactivestreams.Publisher<Point> points) Write Data points into specified bucket.
void	writePoints(String bucket, String org, io.reactivex.Flowable<Point> points) Write Data points into specified bucket.
void	writePoints(String bucket, String org, org.reactivestreams.Publisher<Point> points) Write Data points into specified bucket.
void	writeRecord(String bucket, String org, WritePrecision precision, io.reactivex.Maybe<String> record) Write Line Protocol record into specified bucket.
void	writeRecord(WritePrecision precision, io.reactivex.Maybe<String> record) Write Line Protocol record into specified bucket.
void	writeRecords(String bucket, String org, WritePrecision precision, io.reactivex.Flowable<String> records) Write Line Protocol records into specified bucket.
void	writeRecords(String bucket, String org, WritePrecision precision, org.reactivestreams.Publisher<String> records) Write Line Protocol records into specified bucket.
void	writeRecords(WritePrecision precision, io.reactivex.Flowable<String> records) Write Line Protocol records into specified bucket.
void	writeRecords(WritePrecision precision, org.reactivestreams.Publisher<String> records) Write Line Protocol records into specified bucket.

Method Detail

writeRecord

void writeRecord(@Nonnull
                 WritePrecision precision,
                 @Nonnull
                 io.reactivex.Maybe<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 (optional)

record - specifies the record in InfluxDB Line Protocol. The record is considered as one batch unit.

writeRecord

void writeRecord(@Nonnull
                 String bucket,
                 @Nonnull
                 String org,
                 @Nonnull
                 WritePrecision precision,
                 @Nonnull
                 io.reactivex.Maybe<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 (optional)

record - specifies the record in InfluxDB Line Protocol. The record is considered as one batch unit.

writeRecords

void writeRecords(@Nonnull
                  WritePrecision precision,
                  @Nonnull
                  io.reactivex.Flowable<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 (optional)

records - specifies the records in InfluxDB Line Protocol

writeRecords

void writeRecords(@Nonnull
                  String bucket,
                  @Nonnull
                  String org,
                  @Nonnull
                  WritePrecision precision,
                  @Nonnull
                  io.reactivex.Flowable<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 (optional)

records - specifies the records in InfluxDB Line Protocol

writeRecords

void 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 (optional)

records - specifies the records in InfluxDB Line Protocol

writeRecords

void 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 (optional)

records - specifies the records in InfluxDB Line Protocol

writePoint

void writePoint(@Nonnull
                io.reactivex.Maybe<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:

point - specifies the Data point to write into bucket

writePoint

void writePoint(@Nonnull
                String bucket,
                @Nonnull
                String org,
                @Nonnull
                io.reactivex.Maybe<Point> point)

Write Data point into specified bucket.

Parameters:

bucket - specifies the destination bucket for writes

org - specifies the destination organization for writes

point - specifies the Data point to write into bucket

writePoints

void writePoints(@Nonnull
                 io.reactivex.Flowable<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:

points - specifies the Data points to write into bucket

writePoints

void writePoints(@Nonnull
                 String bucket,
                 @Nonnull
                 String org,
                 @Nonnull
                 io.reactivex.Flowable<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

points - specifies the Data points to write into bucket

writePoints

void writePoints(@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:

points - specifies the Data points to write into bucket

writePoints

void writePoints(@Nonnull
                 String bucket,
                 @Nonnull
                 String org,
                 @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

points - specifies the Data points to write into bucket

writeMeasurement

<M> void writeMeasurement(@Nonnull
                          WritePrecision precision,
                          @Nonnull
                          io.reactivex.Maybe<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 (optional)

measurement - specifies the Measurement to write into bucket

writeMeasurement

<M> void writeMeasurement(@Nonnull
                          String bucket,
                          @Nonnull
                          String org,
                          @Nonnull
                          WritePrecision precision,
                          @Nonnull
                          io.reactivex.Maybe<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 (optional)

measurement - specifies the Measurement to write into bucket

writeMeasurements

<M> void writeMeasurements(@Nonnull
                           WritePrecision precision,
                           @Nonnull
                           io.reactivex.Flowable<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 (optional)

measurements - specifies the Measurements to write into bucket

writeMeasurements

<M> void writeMeasurements(@Nonnull
                           String bucket,
                           @Nonnull
                           String org,
                           @Nonnull
                           WritePrecision precision,
                           @Nonnull
                           io.reactivex.Flowable<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 (optional)

measurements - specifies the Measurements to write into bucket

writeMeasurements

<M> void 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 (optional)

measurements - specifies the Measurements to write into bucket

writeMeasurements

<M> void 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 (optional)

measurements - specifies the Measurements to write into bucket

listenEvents

@Nonnull
<T extends AbstractWriteEvent> io.reactivex.Observable<T> listenEvents(@Nonnull
                                                                                Class<T> eventType)

Listen the events produced by WriteApi.

The WriteApi produces: WriteSuccessEvent, BackpressureEvent, WriteErrorEvent and WriteRetriableErrorEvent.

Type Parameters:

T - type of event to listen

Parameters:

eventType - type of event to listen

Returns:

lister for eventType events

close

void close()

Close threads for asynchronous batch writing.

Specified by:

close in interface AutoCloseable