Package io.openems.shared.influxdb

Class SafeMergePointsWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.worker.AbstractImmediateWorker

io.openems.shared.influxdb.AbstractMergePointsWorker<SafeMergePointsWorker.WritePoint>

io.openems.shared.influxdb.SafeMergePointsWorker

All Implemented Interfaces:

MergePointsWorker

public class SafeMergePointsWorker
extends AbstractMergePointsWorker<SafeMergePointsWorker.WritePoint>
implements MergePointsWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SafeMergePointsWorker.WritePoint

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
SafeMergePointsWorker(InfluxConnector parent, String name, com.influxdb.client.write.WriteParameters writeParameters, Consumer<com.influxdb.exceptions.BadRequestException> onWriteError)

Method Summary

Modifier and Type	Method	Description
boolean	offer(com.influxdb.client.write.Point point)	Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions, returning true upon success and false if no space is currently available.
protected void	onWriteError(Throwable t, List<SafeMergePointsWorker.WritePoint> points)
protected List<com.influxdb.client.write.Point>	writePoints(List<SafeMergePointsWorker.WritePoint> points)

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

activate, debugLog, forever, offer

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

Constructor Details

SafeMergePointsWorker

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

Method Details

offer

public boolean offer(com.influxdb.client.write.Point point)

Description copied from interface: MergePointsWorker

Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions, returning true upon success and false if no space is currently available.

Specified by:

offer in interface MergePointsWorker

Parameters:

point - the Point to add

Returns:

true if the point was added to this queue, else false

writePoints

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

Specified by:

writePoints in class AbstractMergePointsWorker<SafeMergePointsWorker.WritePoint>

onWriteError

protected void onWriteError(Throwable t,
 List<SafeMergePointsWorker.WritePoint> points)

Overrides:

onWriteError in class AbstractMergePointsWorker<SafeMergePointsWorker.WritePoint>