Interface Replicator.Reader

All Superinterfaces:

AutoCloseable, Closeable, Replicator.Accessor

All Known Subinterfaces:

MessageReplicator.Reader, StreamReplicator.Reader

Enclosing interface:

Replicator

public static interface Replicator.Reader
extends Replicator.Accessor

Direct interface for reading from a replicator, for a given term.

Method Summary

Methods inherited from interface Replicator.Accessor

addCommitListener, close, commitPosition, position, term, termEndPosition, termStartPosition, uponCommit, waitForCommit, waitForEndCommit

Modifier and Type	Method	Description
void	addCommitListener(LongConsumer listener)	Install a callback which receives a stream of commit position updates.
void	close()
long	commitPosition()	Returns the current term commit position, which might be lower than the start position.
long	position()	Returns the next log position which will be accessed.
long	term()	Returns the fixed term being accessed.
long	termEndPosition()	Returns the current term end position, which is Long.MAX_VALUE if unbounded.
long	termStartPosition()	Returns the position at the start of the term.
void	uponCommit(long position, LongConsumer task)	Invokes the given task when the commit position reaches the requested position.
long	waitForCommit(long position, long nanosTimeout)	Blocks until the commit position reaches the given position.
default long	waitForEndCommit(long nanosTimeout)	Blocks until the commit position reaches the end of the term.