Package io.openems.backend.timedata.timescaledb.internal.write

Class QueueHandler<T extends Point>

java.lang.Object

io.openems.backend.timedata.timescaledb.internal.write.QueueHandler<T>

Direct Known Subclasses:

QueueHandler.FloatQueueHandler, QueueHandler.IntQueueHandler, QueueHandler.StringQueueHandler

public abstract class QueueHandler<T extends Point>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueueHandler.FloatQueueHandler
static class	QueueHandler.IntQueueHandler
static class	QueueHandler.StringQueueHandler

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	QueueHandler(MergePointsWorker<T> mergePointsWorker, Class<T> pointClass)

Method Summary

Modifier and Type	Method	Description
void	activate()	Activates the MergePointsWorker.
protected abstract T	dataToPointConverter(Schema.ChannelRecord channel, ZonedDateTime time, com.google.gson.JsonElement json)
String	debugLog()	Returns a DebugLog String.
MergePointsWorker<T>	getMergePointsWorker()
static QueueHandler<?>	of(Type type, Priority priority, com.zaxxer.hikari.HikariDataSource dataSource, ExecutorService executor)	Returns a new QueueHandler of the given type.
boolean	offer(Schema.ChannelRecord channel, long timestamp, com.google.gson.JsonElement json)	Adds a point to the handler.

Methods inherited from class java.lang.Object

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

Constructor Details

QueueHandler

protected QueueHandler(MergePointsWorker<T> mergePointsWorker,
 Class<T> pointClass)

Method Details

offer

public boolean offer(Schema.ChannelRecord channel,
 long timestamp,
 com.google.gson.JsonElement json)
              throws OpenemsError.OpenemsNamedException

Adds a point to the handler.

Parameters:

channel - the channel

timestamp - the timestamp

json - the value

Returns:

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

Throws:

OpenemsError.OpenemsNamedException - on error

getMergePointsWorker

public MergePointsWorker<T> getMergePointsWorker()

debugLog

public String debugLog()

Returns a DebugLog String.

Returns:

debug log

dataToPointConverter

protected abstract T dataToPointConverter(Schema.ChannelRecord channel,
 ZonedDateTime time,
 com.google.gson.JsonElement json)
                                   throws OpenemsError.OpenemsNamedException

Throws:

OpenemsError.OpenemsNamedException

activate

public void activate()

Activates the MergePointsWorker.

of

public static QueueHandler<?> of(Type type,
 Priority priority,
 com.zaxxer.hikari.HikariDataSource dataSource,
 ExecutorService executor)

Returns a new QueueHandler of the given type.

Parameters:

type - the type of the handler

priority - the priority of the handler

dataSource - the dataSource to get database connections

executor - the executor to execute writes

Returns:

the handler