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 newPosition)	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 newPosition)	Merges two Position objects by taking the highest known index per segment.

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, PositionStore positionStore, 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 List<SerializedMessage>	DefaultTrackingStrategy.getBatch(int[] segment, Position position, int batchSize)

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)