Package io.fluxcapacitor.common.api.tracking

Class Position

java.lang.Object

io.fluxcapacitor.common.api.tracking.Position

public class Position
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static int[]	FULL_SEGMENT
static int	MAX_SEGMENT

Constructor Summary

Constructors

Constructor	Description
Position(int[] segment, long index)
Position(long index)

Method Summary

Modifier and Type	Method	Description
Optional<Long>	getIndex(int segment)
boolean	isNew(int[] segment)
boolean	isNewIndex(int segment, Long messageIndex)
boolean	isNewMessage(SerializedMessage message)
Optional<Long>	lowestIndexForSegment(int[] segment)
Position	merge(Position newPosition)
static Position	newPosition()
Map<int[],Long>	splitInSegments()

Methods inherited from class java.lang.Object

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

Field Details

MAX_SEGMENT

public static int MAX_SEGMENT

FULL_SEGMENT

public static int[] FULL_SEGMENT

Constructor Details

Position

public Position(long index)

Position

public Position(int[] segment,
 long index)

Method Details

newPosition

public static Position newPosition()

getIndex

public Optional<Long> getIndex(int segment)

isNew

public boolean isNew(int[] segment)

lowestIndexForSegment

public Optional<Long> lowestIndexForSegment(int[] segment)

merge

public Position merge(Position newPosition)

splitInSegments

public Map<int[],Long> splitInSegments()

isNewMessage

public boolean isNewMessage(SerializedMessage message)

isNewIndex

public boolean isNewIndex(int segment,
 Long messageIndex)