Package com.linkedin.venice.pushmonitor

Class RouterBasedHybridStoreQuotaMonitor

java.lang.Object

com.linkedin.venice.pushmonitor.RouterBasedHybridStoreQuotaMonitor

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class RouterBasedHybridStoreQuotaMonitor
extends java.lang.Object
implements java.io.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, java.lang.String storeName, Version.PushType pushType, java.lang.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 Detail

RouterBasedHybridStoreQuotaMonitor

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

Method Detail

start

public void start()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

getHybridQuotaMonitorTask

protected RouterBasedHybridStoreQuotaMonitor.HybridQuotaMonitorTask getHybridQuotaMonitorTask()

setCurrentStatus

public void setCurrentStatus(HybridStoreQuotaStatus currentStatus)

getCurrentStatus

public HybridStoreQuotaStatus getCurrentStatus()