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.
|