Package com.linkedin.venice.meta
Interface RoutingDataRepository.RoutingDataChangedListener
-
- All Known Implementing Classes:
AbstractPushMonitor
,AggPartitionHealthStats
,PartitionStatusBasedPushMonitor
,ReadQuotaEnforcementHandler
- Enclosing interface:
- RoutingDataRepository
public static interface RoutingDataRepository.RoutingDataChangedListener
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onCustomizedViewAdded(PartitionAssignment partitionAssignment)
void
onCustomizedViewChange(PartitionAssignment partitionAssignment)
void
onExternalViewChange(PartitionAssignment partitionAssignment)
Handle routing data changed event.void
onPartitionStatusChange(java.lang.String topic, ReadOnlyPartitionStatus partitionStatus)
void
onRoutingDataDeleted(java.lang.String kafkaTopic)
-
-
-
Method Detail
-
onExternalViewChange
void onExternalViewChange(PartitionAssignment partitionAssignment)
Handle routing data changed event.- Parameters:
partitionAssignment
- Newest partitions assignments information including resource name and all of instances assigned to this resource. If the number of partition is 0, it means the kafka topic is deleted.
-
onCustomizedViewChange
void onCustomizedViewChange(PartitionAssignment partitionAssignment)
-
onCustomizedViewAdded
void onCustomizedViewAdded(PartitionAssignment partitionAssignment)
-
onPartitionStatusChange
void onPartitionStatusChange(java.lang.String topic, ReadOnlyPartitionStatus partitionStatus)
-
onRoutingDataDeleted
void onRoutingDataDeleted(java.lang.String kafkaTopic)
-
-