Package io.fluxzero.common.tracking

package io.fluxzero.common.tracking

Related Packages

Package	Description
io.fluxzero.common

Class	Description
DefaultTrackingStrategy	Streaming strategy that allows multiple clients to concurrently consume a message stream.
HasMessageStore	Interface for components that expose a MessageStore.
InMemoryPositionStore
MessageStore	A low-level store for serialized messages.
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