Package io.openems.edge.timedata.api

Class Timeranges

java.lang.Object

io.openems.edge.timedata.api.Timeranges

public class Timeranges
extends Object

Bundle class of multiple Timeranges.Timerange. Used to get the timeranges to resend data from.

All Timeranges.Timerange inside a Timeranges are separated by the MAX_CONCAT_TIME. When inserting a new timestamp the timestamp gets inserted to the nearest Timeranges.Timerange or if the nearest one is more than the MAX_CONCAT_TIME away a new Timeranges.Timerange gets inserted in the current Timeranges.

Usage example:

 final var timeranges = timedata.getResendTimeranges([CHANNEL_ADDRESS], [LAST_RESEND_TIMESTAMP]);
 for (var timerange : timeranges.maxDataInTime([MAX_RESEND_TIMESPAN_SECONDS])) {
        final var from = timerange.getMinTimestamp();
        final var to = timerange.getMaxTimestamp();
        ...fetch resend data
        ...send data
 }
 

See Also:

• Timedata.getResendTimeranges(io.openems.common.types.ChannelAddress, long)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Timeranges.Timerange

Field Summary

Fields

Modifier and Type	Field	Description
protected static final long	MAX_CONCAT_TIME
protected static final Comparator<Timeranges.Timerange>	TIMERANGE_COMPARATOR

Constructor Summary

Constructors

Constructor	Description
Timeranges()

Method Summary

Modifier and Type	Method	Description
List<Timeranges.Timerange>	getTimerangeAscending()	Gets the Timeranges in ascending order.
void	insert(long timestamp)	Inserts a timestamp in seconds into this Timeranges.
Iterable<Timeranges.Timerange>	maxDataInTime(long maxTimerange)	Creates an Iterable which iterates over new Timeranges where the max size of one Timeranges.Timerange is the given maxTimerange.
Timeranges	withBuffer(long beforeBuffer, long afterBuffer)	Creates a new Timeranges with the given buffers before and after every Timeranges.Timerange.

Methods inherited from class java.lang.Object

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

Field Details

MAX_CONCAT_TIME

protected static final long MAX_CONCAT_TIME

See Also:

• Constant Field Values

TIMERANGE_COMPARATOR

protected static final Comparator<Timeranges.Timerange> TIMERANGE_COMPARATOR

Constructor Details

Timeranges

public Timeranges()

Method Details

insert

public void insert(long timestamp)

Inserts a timestamp in seconds into this Timeranges.

Parameters:

timestamp - the timestamp to inserts in seconds

getTimerangeAscending

public List<Timeranges.Timerange> getTimerangeAscending()

Gets the Timeranges in ascending order.

Returns:

a list of the Timeranges

withBuffer

public Timeranges withBuffer(long beforeBuffer,
 long afterBuffer)

Creates a new Timeranges with the given buffers before and after every Timeranges.Timerange.

Parameters:

beforeBuffer - the buffer before every Timeranges.Timerange

afterBuffer - the buffer after every Timeranges.Timerange

Returns:

the new Timeranges with the buffer

maxDataInTime

public Iterable<Timeranges.Timerange> maxDataInTime(long maxTimerange)

Creates an Iterable which iterates over new Timeranges where the max size of one Timeranges.Timerange is the given maxTimerange.

Parameters:

maxTimerange - the maximal timerange of one Timeranges.Timerange in seconds

Returns:

a new Iterable