Package io.fluxzero.common.api.tracking
package io.fluxzero.common.api.tracking
-
ClassesClassDescriptionA request to claim a message segment for consumption in client-controlled tracking mode.Result of a
ClaimSegmentrequest.Lightweight metric representation of aClaimSegmentResult, used for telemetry.Command used to explicitly disconnect a tracker from the Fluxzero Runtime and release any claimed message segments.Response to aGetPositionrequest, containing the current tracked position for a specific consumer andMessageType.Represents a batch of messages retrieved from the message store for a specific segment range.Compact summary of aMessageBatch, used for logging and performance tracking.Represents the tracking state of a consumer, i.e. the last known indexes of consumed messages per segment.Command to read a batch of messages from the Fluxzero Runtime for a given consumer and tracker.Request to fetch a batch of messages from a given log starting from a given index.Result for aReadFromIndexrequest.Metric representation of aReadFromIndexResult, used for internal monitoring and analytics.Result returned in response to aReadrequest for a batch of messages.Compact representation of theReadResultused for monitoring.Command to forcibly reset the tracked position for a given consumer and message type.Command sent to the Fluxzero Runtime to update the tracked position for a specific consumer and segment range.