Package com.linkedin.venice.datarecovery

Class DataRecoveryClient

java.lang.Object

com.linkedin.venice.datarecovery.DataRecoveryClient

public class DataRecoveryClient
extends 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(Set<String> storeNames)
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 Details

DataRecoveryClient

public DataRecoveryClient()

DataRecoveryClient

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

Method Details

getExecutor

public DataRecoveryExecutor getExecutor()

getEstimator

public DataRecoveryEstimator getEstimator()

getMonitor

public DataRecoveryMonitor getMonitor()

execute

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

estimateRecoveryTime

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

monitor

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

confirmStores

public boolean confirmStores(Set<String> storeNames)