Package com.linkedin.venice.pushmonitor

Interface Summary

Interface	Description
DisableReplicaCallback	The callback method to disable leader replicas whenever they are in ERROR state so that helix can elect a new leader.
OfflinePushAccessor	Accessor to execute the CURD operations for offline push and its replicas statuses.
PartitionStatusListener	Listener used to listen the data change of partition status.
PushMonitor	In Venice, Push is a task that asynchronously writes data to Venice.
RouterBasedHybridStoreQuotaMonitor.TransportClientReinitProvider

Class Summary

Class	Description
AbstractPushMonitor	AbstractPushMonitor is a high level abstraction that manages OfflinePushStatus.
AggPushHealthStats
AggPushStatusCleanUpStats
ExecutionStatusWithDetails
HelixCVBasedPushMonitor	An implementation of AbstractPushMonitor that listens to Helix Customized View to determine the push status
KillOfflinePushMessage
LeakedPushStatusCleanUpService	LeakedPushStatusCleanUpService will wake up regularly (interval is determined by controller config ConfigKeys.LEAKED_PUSH_STATUS_CLEAN_UP_SERVICE_SLEEP_INTERVAL_MS), get all existing push status ZNodes on Zookeeper that belong to the specified cluster, without scanning through the replica statuses, find all leaked push status and delete them on Zookeeper.
OfflinePushStatus	Class stores all the statuses and history of one offline push.
PartitionStatus	Class stores the status of one partition including all the replicas statuses in this partition.
PartitionStatusBasedPushMonitor	An implementation of AbstractPushMonitor that listens to ZK PartitionStatus to determine the push status.
PushHealthStats
PushMonitorDelegator	This class maintains the mapping of Kafka topic to each PushMonitor instance and delegates calls to the correct instance.
PushMonitorUtils	This class contains some common util methods for push monitoring purpose.
PushStatusCleanUpStats
PushStatusCollector	This class serves as a collector of offline push status for both Venice Server and Da Vinci clients.
PushStatusDecider	Decide the offline push status by checking all replicas statuses under different offline push strategies.
ReadOnlyPartitionStatus
ReplicaStatus	Class stores replica status and history.
RouterBasedHybridStoreQuotaMonitor	This push monitor is able to query hybrid store quota status from routers
RouterBasedHybridStoreQuotaMonitor.HybridQuotaMonitorTask
RouterBasedPushMonitor	This push monitor is able to query push job status from routers; it only works for stores running in Leader/Follower mode and it will be built for STREAM_REPROCESSING job.
StatusSnapshot	The snapshot of status change.
WaitAllPushStatusDecider	Wait all strategy stands for Venice do not allow one replica to be failed.
WaitNMinusOnePushStatusDecider	Wait N-1 strategy stands for Venice could tolerate one of replica to be failed for each partition.

Enum Summary

Enum	Description
ExecutionStatus	Status of executing off-line push.
HybridStoreQuotaStatus
PushMonitorType	This enum controls the behavior of how PushMonitorDelegator chooses proper PushMonitor for resources.
PushStatusCleanUpServiceState