Class | Description |
---|---|
GlobalCheckpointSyncAction |
Background global checkpoint sync action initiated when a shard goes inactive.
|
GlobalCheckpointSyncAction.Request | |
GlobalCheckpointTracker |
This class is responsible of tracking the global checkpoint.
|
GlobalCheckpointTracker.CheckpointState | |
GlobalCheckpointTracker.PrimaryContext |
Represents the sequence number component of the primary context.
|
LocalCheckpointTracker |
This class generates sequences numbers and keeps track of the so-called "local checkpoint" which is the highest number for which all
previous sequence numbers have been processed (inclusive).
|
SeqNoStats | |
SequenceNumbers |
A utility class for handling sequence numbers.
|
SequenceNumbersService |
Encapsulates the local and global checkpoints into a single service for use as a shard component.
|