Package io.fluxcapacitor.common.tracking

Class InMemoryPositionStore

java.lang.Object

io.fluxcapacitor.common.tracking.InMemoryPositionStore

All Implemented Interfaces:

PositionStore

public class InMemoryPositionStore
extends Object
implements PositionStore

Constructor Summary

Constructors

Constructor	Description
InMemoryPositionStore()

Method Summary

Modifier and Type	Method	Description
void	close()
Position	position(String consumer)
CompletableFuture<Void>	resetPosition(String consumer, long lastIndex)
CompletableFuture<Void>	storePosition(String consumer, int[] segment, long lastIndex)

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryPositionStore

public InMemoryPositionStore()

Method Details

storePosition

public CompletableFuture<Void> storePosition(String consumer,
 int[] segment,
 long lastIndex)

Specified by:

storePosition in interface PositionStore

resetPosition

public CompletableFuture<Void> resetPosition(String consumer,
 long lastIndex)

Specified by:

resetPosition in interface PositionStore

position

public Position position(String consumer)

Specified by:

position in interface PositionStore

close

public void close()

Specified by:

close in interface PositionStore