Uses of Class
io.fluxzero.common.api.tracking.Position

Packages that use Position

Package	Description
io.fluxzero.common.api.tracking
io.fluxzero.common.tracking
io.fluxzero.sdk.tracking.client

Uses of Position in io.fluxzero.common.api.tracking

Methods in io.fluxzero.common.api.tracking that return Position

Modifier and Type	Method	Description
Position	Position.merge(Position other)	Merges two Position objects by taking the highest known index per segment.
static Position	Position.newPosition()	Creates an empty position.

Methods in io.fluxzero.common.api.tracking with parameters of type Position

Modifier and Type	Method	Description
Position	Position.merge(Position other)	Merges two Position objects by taking the highest known index per segment.

Constructors in io.fluxzero.common.api.tracking with parameters of type Position

Modifier	Constructor	Description
	MessageBatch(int[] segment, List<SerializedMessage> messages, Long lastIndex, Position position, boolean caughtUp)	Creates an ordinary data batch; the optional filter-control flag is handled by the JSON factory.

Uses of Position in io.fluxzero.common.tracking

Methods in io.fluxzero.common.tracking that return Position

Modifier and Type	Method	Description
protected Position	DefaultTrackingStrategy.position(Tracker tracker, int[] segment)
Position	InMemoryPositionStore.position(String consumer)
Position	PositionStore.position(String consumer)	Retrieves the full multi-segment position for the given consumer.

Methods in io.fluxzero.common.tracking with parameters of type Position

Modifier and Type	Method	Description
protected List<SerializedMessage>	DefaultTrackingStrategy.filter(List<SerializedMessage> messages, int[] segmentRange, Position position, Tracker tracker)
protected Predicate<SerializedMessage>	DefaultTrackingStrategy.filterPredicate(int[] segmentRange, Position position, Tracker tracker)
protected List<SerializedMessage>	DefaultTrackingStrategy.getBatch(int[] segment, Position position, int batchSize)
protected MessageStoreBatch	DefaultTrackingStrategy.scanBatch(int[] segment, Position position, int batchSize, long maxBytes, Predicate<? super SerializedMessage> filter)
protected MessageStoreBatch	DefaultTrackingStrategy.scanBatch(int[] segment, Position position, int batchSize, long maxBytes, Predicate<? super SerializedMessage> filter, boolean includeDocumentTombstones)

Uses of Position in io.fluxzero.sdk.tracking.client

Methods in io.fluxzero.sdk.tracking.client that return Position

Modifier and Type	Method	Description
Position	CachingTrackingClient.getPosition(String consumer)
Position	LocalTrackingClient.getPosition(String consumer)
Position	TrackingClient.getPosition(String consumer)	Returns the current committed tracking position for the given consumer.
Position	WebsocketTrackingClient.getPosition(String consumer)

Methods in io.fluxzero.sdk.tracking.client with parameters of type Position

Modifier and Type	Method	Description
protected List<SerializedMessage>	CachingTrackingClient.filterMessages(List<SerializedMessage> messages, int[] segmentRange, Position position, ConsumerConfiguration config)
protected Predicate<SerializedMessage>	CachingTrackingClient.filterPredicate(int[] segmentRange, Position position, ConsumerConfiguration config)