| AbstractPartitionStateModel |
An abstraction of Helix State model behavior registry that defines how participants
(Storage node) fetch data from Kafka.
|
| AbstractStateModelFactory |
ModelFactory manages Helix state model creation.
|
| HelixParticipationService |
Venice Participation Service wrapping Helix Participant.
|
| LeaderFollowerIngestionProgressNotifier |
|
| LeaderFollowerPartitionStateModel |
Venice partition's state model to manage Leader/Follower(Standby) state transitions.
|
| LeaderFollowerPartitionStateModel.LeaderSessionIdChecker |
A leader session id checker will be created for each consumer action;
server checks whether the session id is still valid before processing
the consumer action.
|
| LeaderFollowerPartitionStateModelDualPoolFactory |
|
| LeaderFollowerPartitionStateModelFactory |
State Transition Handler factory for handling Leader/Follower resources in the storage node.
|
| StateModelIngestionProgressNotifier |
This class notifies the Helix State Models (SM) about corresponding ingestion progress.
|