Package io.fluxzero.common.api.tracking

package io.fluxzero.common.api.tracking

Related Packages

Package	Description
io.fluxzero.common.api

Classes

Class	Description
ClaimSegment	A request to claim a message segment for consumption in client-controlled tracking mode.
ClaimSegmentResult	Result of a ClaimSegment request.
ClaimSegmentResult.Metric	Lightweight metric representation of a ClaimSegmentResult, used for telemetry.
DisconnectTracker	Command used to explicitly disconnect a tracker from the Fluxzero Runtime and release any claimed message segments.
GetPosition	Query to retrieve the current tracked Position for a given consumer and MessageType.
GetPositionResult	Response to a GetPosition request, containing the current tracked position for a specific consumer and MessageType.
MessageBatch	Represents a batch of messages retrieved from the message store for a specific segment range.
MessageBatch.Metric	Compact summary of a MessageBatch, used for logging and performance tracking.
Position	Represents the tracking state of a consumer, i.e. the last known indexes of consumed messages per segment.
Read	Command to read a batch of messages from the Fluxzero Runtime for a given consumer and tracker.
ReadFromIndex	Request to fetch a batch of messages from a given log starting from a given index.
ReadFromIndexResult	Result for a ReadFromIndex request.
ReadFromIndexResult.Metric	Metric representation of a ReadFromIndexResult, used for internal monitoring and analytics.
ReadResult	Result returned in response to a Read request for a batch of messages.
ReadResult.Metric	Compact representation of the ReadResult used for monitoring.
ResetPosition	Command to forcibly reset the tracked position for a given consumer and message type.
StorePosition	Command sent to the Fluxzero Runtime to update the tracked position for a specific consumer and segment range.