Package io.fluxcapacitor.common

Class IndexUtils

java.lang.Object

io.fluxcapacitor.common.IndexUtils

public class IndexUtils
extends Object

Use 48 bits of the current time in milliseconds since epoch as the base of the index. The remaining 16 bits (65k) are used to increment the index if messages are written in the same ms as the last batch.

The index is only able to store 2^47 - 1 ms of time since epoch, i.e. about 4,500 years.

Field Summary

Fields

Modifier and Type	Field	Description
static ThreadLocal<Clock>	clock

Constructor Summary

Constructors

Constructor	Description
IndexUtils()

Method Summary

Modifier and Type	Method	Description
static Instant	currentTime()
static long	currentTimeMillis()
static long	indexForCurrentTime()
static long	indexFromMillis(long millisSinceEpoch)
static long	indexFromTimestamp(Instant timestamp)
static long	millisFromIndex(long index)
static int	offsetFromIndex(long index)
static Instant	timestampFromIndex(long index)

Methods inherited from class java.lang.Object

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

Field Details

clock

public static final ThreadLocal<Clock> clock

Constructor Details

IndexUtils

public IndexUtils()

Method Details

currentTime

public static Instant currentTime()

currentTimeMillis

public static long currentTimeMillis()

millisFromIndex

public static long millisFromIndex(long index)

timestampFromIndex

public static Instant timestampFromIndex(long index)

indexFromTimestamp

public static long indexFromTimestamp(Instant timestamp)

indexFromMillis

public static long indexFromMillis(long millisSinceEpoch)

indexForCurrentTime

public static long indexForCurrentTime()

offsetFromIndex

public static int offsetFromIndex(long index)