public class RpoMetricsManager extends Object implements TierReplicaManager.ChangeListener
Constructor and Description |
---|
RpoMetricsManager(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
addNewSegment(TopicIdPartition topicIdPartition,
long baseOffset) |
void |
onBecomeFollower(TopicIdPartition topicIdPartition)
Fired when this topic partition becomes follower.
|
void |
onBecomeLeader(TopicIdPartition topicIdPartition,
int leaderEpoch)
Implement methods for TierReplicaManager.ChangeListener
|
void |
onDelete(TopicIdPartition topicIdPartition)
Fired when this topic partition is deleted.
|
PartitionRpo |
partitionRpo(TopicIdPartition topicIdPartition) |
void |
registerTopicIdPartition(TopicIdPartition topicIdPartition)
Hook methods, which will be called in corresponding segment lifecycle.
|
void |
unregisterTopicIdPartition(TopicIdPartition topicIdPartition) |
void |
updateRpoValues(kafka.log.LogManager logManager) |
public RpoMetricsManager(org.apache.kafka.common.utils.Time time)
public void updateRpoValues(kafka.log.LogManager logManager)
public void registerTopicIdPartition(TopicIdPartition topicIdPartition)
public void unregisterTopicIdPartition(TopicIdPartition topicIdPartition)
public void addNewSegment(TopicIdPartition topicIdPartition, long baseOffset)
public PartitionRpo partitionRpo(TopicIdPartition topicIdPartition)
public void onBecomeLeader(TopicIdPartition topicIdPartition, int leaderEpoch)
onBecomeLeader
in interface TierReplicaManager.ChangeListener
public void onBecomeFollower(TopicIdPartition topicIdPartition)
TierReplicaManager.ChangeListener
onBecomeFollower
in interface TierReplicaManager.ChangeListener
public void onDelete(TopicIdPartition topicIdPartition)
TierReplicaManager.ChangeListener
onDelete
in interface TierReplicaManager.ChangeListener