Package com.linkedin.venice.datarecovery

Class DataRecoveryClient

java.lang.Object

com.linkedin.venice.datarecovery.DataRecoveryClient

public class DataRecoveryClient
extends java.lang.Object

DataRecoveryClient is the central class to manage data recovery feature. It contains three main modules: a data recovery planner, a data recovery executor, and a data recovery monitor. Depending on the different use cases, it delegates the tasks to a specific module.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DataRecoveryClient.DataRecoveryParams

Constructor Summary

Constructors

Constructor	Description
DataRecoveryClient()
DataRecoveryClient(DataRecoveryExecutor executor, DataRecoveryMonitor monitor, DataRecoveryEstimator estimator)

Method Summary

Modifier and Type	Method	Description
boolean	confirmStores(java.util.Set<java.lang.String> storeNames)
java.lang.Long	estimateRecoveryTime(DataRecoveryClient.DataRecoveryParams drParams, EstimateDataRecoveryTimeCommand.Params cmdParams)
void	execute(DataRecoveryClient.DataRecoveryParams drParams, StoreRepushCommand.Params cmdParams)
DataRecoveryEstimator	getEstimator()
DataRecoveryExecutor	getExecutor()
DataRecoveryMonitor	getMonitor()
void	monitor(DataRecoveryClient.DataRecoveryParams drParams, MonitorCommand.Params monitorParams)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataRecoveryClient

public DataRecoveryClient()

DataRecoveryClient

public DataRecoveryClient(DataRecoveryExecutor executor,
                          DataRecoveryMonitor monitor,
                          DataRecoveryEstimator estimator)

Method Detail

getExecutor

public DataRecoveryExecutor getExecutor()

getEstimator

public DataRecoveryEstimator getEstimator()

getMonitor

public DataRecoveryMonitor getMonitor()

execute

public void execute(DataRecoveryClient.DataRecoveryParams drParams,
                    StoreRepushCommand.Params cmdParams)

estimateRecoveryTime

public java.lang.Long estimateRecoveryTime(DataRecoveryClient.DataRecoveryParams drParams,
                                           EstimateDataRecoveryTimeCommand.Params cmdParams)

monitor

public void monitor(DataRecoveryClient.DataRecoveryParams drParams,
                    MonitorCommand.Params monitorParams)

confirmStores

public boolean confirmStores(java.util.Set<java.lang.String> storeNames)