Package com.linkedin.venice.pushmonitor

Class RouterBasedHybridStoreQuotaMonitor

java.lang.Object

com.linkedin.venice.pushmonitor.RouterBasedHybridStoreQuotaMonitor

All Implemented Interfaces:

Closeable, AutoCloseable

public class RouterBasedHybridStoreQuotaMonitor
extends Object
implements Closeable

This push monitor is able to query hybrid store quota status from routers

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	RouterBasedHybridStoreQuotaMonitor.HybridQuotaMonitorTask
static interface	RouterBasedHybridStoreQuotaMonitor.TransportClientReinitProvider

Constructor Summary

Constructors

Constructor	Description
RouterBasedHybridStoreQuotaMonitor(TransportClient transportClient, String storeName, Version.PushType pushType, String topicName, RouterBasedHybridStoreQuotaMonitor.TransportClientReinitProvider reinitProvider)

Method Summary

Modifier and Type	Method	Description
void	close()
HybridStoreQuotaStatus	getCurrentStatus()
protected RouterBasedHybridStoreQuotaMonitor.HybridQuotaMonitorTask	getHybridQuotaMonitorTask()
void	setCurrentStatus(HybridStoreQuotaStatus currentStatus)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RouterBasedHybridStoreQuotaMonitor

public RouterBasedHybridStoreQuotaMonitor(TransportClient transportClient,
 String storeName,
 Version.PushType pushType,
 String topicName,
 RouterBasedHybridStoreQuotaMonitor.TransportClientReinitProvider reinitProvider)

Method Details

start

public void start()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getHybridQuotaMonitorTask

protected RouterBasedHybridStoreQuotaMonitor.HybridQuotaMonitorTask getHybridQuotaMonitorTask()

setCurrentStatus

public void setCurrentStatus(HybridStoreQuotaStatus currentStatus)

getCurrentStatus

public HybridStoreQuotaStatus getCurrentStatus()