Package io.fluxcapacitor.common.tracking

Interface PositionStore

All Known Implementing Classes:

InMemoryPositionStore

public interface PositionStore

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)

Method Details

storePosition

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

resetPosition

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

position

Position position(String consumer)

close

void close()