Package io.fluxzero.common.tracking

package io.fluxzero.common.tracking

Related Packages

Package	Description
io.fluxzero.common

Class	Description
ClaimResult	Result of a segment claim in the tracking strategy domain.
DefaultTrackingStrategy	Streaming strategy that allows multiple clients to concurrently consume a message stream.
DefaultTrackingStrategy.TrackerRequest<T>
HasMessageStore	Interface for components that expose a MessageStore.
InMemoryPositionStore
MessageLogMaintenance	Coordinates maintenance operations that span the message log, tracking positions and active trackers.
MessageStore	A low-level store for serialized messages.
MessageStoreBatch	Result of scanning a message store for a tracking batch.
PositionStore	Interface for storing and retrieving Position objects representing the last processed message indexes per segment for a given consumer.
SimpleTracker
Tracker	A Tracker represents an active consumer of messages for a particular ConsumerConfiguration.
TrackerCluster	Represents the current set of Trackers that are connected for a specific consumer.
TrackingStrategy	A TrackingStrategy defines how a Tracker consumes messages from a message log or distributed segment space.
WebSocketTracker