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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
completeCoreWorkWithError(java.lang.String error)
void
completeCoreWorkWithMessage(java.lang.String message)
void
execute()
StoreRepushCommand.Params
getParams()
RepushViabilityInfo
getRepushViability()
StoreRepushCommand.Result
getResult()
java.util.List<java.lang.String>
getShellCmd()
RepushViabilityInfo.Result
getViabilityResult()
boolean
isShellCmdExecuted()
boolean
needWaitForFirstTaskToComplete()
void
setParams(StoreRepushCommand.Params params)
java.lang.String
toString()
-
Methods inherited from class com.linkedin.venice.datarecovery.Command
buildControllerClient
-
-
-
-
Constructor Detail
-
StoreRepushCommand
public StoreRepushCommand()
-
StoreRepushCommand
public StoreRepushCommand(StoreRepushCommand.Params params)
-
-
Method Detail
-
setParams
public void setParams(StoreRepushCommand.Params params)
-
getParams
public StoreRepushCommand.Params getParams()
-
getResult
public StoreRepushCommand.Result getResult()
-
needWaitForFirstTaskToComplete
public boolean needWaitForFirstTaskToComplete()
- Specified by:
needWaitForFirstTaskToComplete
in classCommand
-
isShellCmdExecuted
public boolean isShellCmdExecuted()
-
completeCoreWorkWithMessage
public void completeCoreWorkWithMessage(java.lang.String message)
-
completeCoreWorkWithError
public void completeCoreWorkWithError(java.lang.String error)
-
getShellCmd
public java.util.List<java.lang.String> getShellCmd()
-
getViabilityResult
public RepushViabilityInfo.Result getViabilityResult()
-
getRepushViability
public RepushViabilityInfo getRepushViability()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-