Package io.openems.shared.influxdb

Class ForceMergePointsWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.worker.AbstractImmediateWorker

io.openems.shared.influxdb.AbstractMergePointsWorker<com.influxdb.client.write.Point>

io.openems.shared.influxdb.ForceMergePointsWorker

All Implemented Interfaces:

MergePointsWorker

public class ForceMergePointsWorker
extends AbstractMergePointsWorker<com.influxdb.client.write.Point>
implements MergePointsWorker

Field Summary

Fields inherited from class io.openems.shared.influxdb.AbstractMergePointsWorker

parent, writeParameters

Fields inherited from class io.openems.common.worker.AbstractWorker

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT, thread

Constructor Summary

Constructors

Constructor	Description
ForceMergePointsWorker(InfluxConnector parent, String name, com.influxdb.client.write.WriteParameters writeParameters, Consumer<com.influxdb.exceptions.BadRequestException> onWriteError)

Method Summary

Modifier and Type	Method	Description
protected List<com.influxdb.client.write.Point>	writePoints(List<com.influxdb.client.write.Point> points)

Methods inherited from class io.openems.shared.influxdb.AbstractMergePointsWorker

activate, debugLog, forever, offer, onWriteError

Methods inherited from class io.openems.common.worker.AbstractImmediateWorker

activate, deactivate, getCycleTime

Methods inherited from class io.openems.common.worker.AbstractWorker

activate, modified, modified, setPriority, triggerNextRun

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.openems.shared.influxdb.MergePointsWorker

activate, deactivate, debugLog, offer

Constructor Details

ForceMergePointsWorker

public ForceMergePointsWorker(InfluxConnector parent,
 String name,
 com.influxdb.client.write.WriteParameters writeParameters,
 Consumer<com.influxdb.exceptions.BadRequestException> onWriteError)

Method Details

writePoints

protected List<com.influxdb.client.write.Point> writePoints(List<com.influxdb.client.write.Point> points)

Specified by:

writePoints in class AbstractMergePointsWorker<com.influxdb.client.write.Point>