Package com.linkedin.venice.datarecovery

Class StoreRepushCommand

java.lang.Object

com.linkedin.venice.datarecovery.Command

com.linkedin.venice.datarecovery.StoreRepushCommand

public class StoreRepushCommand
extends Command

StoreRepushCommand contains the details of executing/processing repush command. We expect the command to comply with the following contract: Input: [] --store --fabric Output: success: link_to_running_task failure: failure_reason

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StoreRepushCommand.Params
static class	StoreRepushCommand.Result

Constructor Summary

Constructors

Constructor	Description
StoreRepushCommand()
StoreRepushCommand(StoreRepushCommand.Params params)

Method Summary

Modifier and Type	Method	Description
void	completeCoreWorkWithError(String error)
void	completeCoreWorkWithMessage(String message)
void	execute()
StoreRepushCommand.Params	getParams()
RepushViabilityInfo	getRepushViability()
StoreRepushCommand.Result	getResult()
List<String>	getShellCmd()
RepushViabilityInfo.Result	getViabilityResult()
boolean	isShellCmdExecuted()
boolean	needWaitForFirstTaskToComplete()
void	setParams(StoreRepushCommand.Params params)
String	toString()

Methods inherited from class com.linkedin.venice.datarecovery.Command

buildControllerClient

Methods inherited from class java.lang.Object

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

Constructor Details

StoreRepushCommand

public StoreRepushCommand()

StoreRepushCommand

public StoreRepushCommand(StoreRepushCommand.Params params)

Method Details

setParams

public void setParams(StoreRepushCommand.Params params)

getParams

public StoreRepushCommand.Params getParams()

getResult

public StoreRepushCommand.Result getResult()

Specified by:

getResult in class Command

needWaitForFirstTaskToComplete

public boolean needWaitForFirstTaskToComplete()

Specified by:

needWaitForFirstTaskToComplete in class Command

isShellCmdExecuted

public boolean isShellCmdExecuted()

completeCoreWorkWithMessage

public void completeCoreWorkWithMessage(String message)

completeCoreWorkWithError

public void completeCoreWorkWithError(String error)

getShellCmd

public List<String> getShellCmd()

getViabilityResult

public RepushViabilityInfo.Result getViabilityResult()

getRepushViability

public RepushViabilityInfo getRepushViability()

execute

public void execute()

Specified by:

execute in class Command

toString

public String toString()

Overrides:

toString in class Object